Написать запрос ESQ на серверной стороне

Добрый день!

Подскажите, пожалуйста, как реализовать данный ESQ запрос:

select c.Id, c.Name, count(1) as AmountOfLeadHandled
from Lead l inner join Contact c on c.Id=l.OwnerId 
where exists (select 1 from Activity a
	where a.LeadId=l.id
	and not (a.TypeId='E2831DEC-CFC0-DF11-B00F-001D60E938C6' 
		and a.MessageTypeId='7F9D1F86-F36B-1410-068C-20CF30B39373')
	and a.StatusId in ('4BDBB88F-58E6-DF11-971B-001D60E938C6'))
	Group by c.Id, c.Name

Есть такой код:

var schema = _userConnection.EntitySchemaManager.GetInstanceByName("Lead");
EntitySchemaQuery esqTotal = new EntitySchemaQuery(schema);
esqTotal.AddColumn("=Owner.Id");
esqTotal.AddColumn("=Owner.Name");
esqTotal.AddColumn(esqTotal.CreateAggregationFunction(Terrasoft.Common.AggregationTypeStrict.Count, "Id"));
var activityTypeId = new Guid("E2831DEC-CFC0-DF11-B00F-001D60E938C6");
var activitymessageTypeId = new Guid("7F9D1F86-F36B-1410-068C-20CF30B39373");
var activityStatusId = new Guid("4BDBB88F-58E6-DF11-971B-001D60E938C6");
var esqActivity = new EntitySchemaQuery(UserConnection.EntitySchemaManager, "Activity");
esqActivity.AddColumn("Lead");
var filtersByExisting = new EntitySchemaQueryFilterCollection(esqActivity);
filtersByExisting.IsNot = true;
filtersByExisting.Add(esqActivity.CreateFilterWithParameters(FilterComparisonType.Equal, "Type", activityTypeId));
filtersByExisting.Add(esqActivity.CreateFilterWithParameters(FilterComparisonType.Equal,                 "MessageType", activitymessageTypeId));
esqActivity.Filters.Add(filtersByExisting);
esqActivity.Filters.Add(esqActivity.CreateFilterWithParameters(FilterComparisonType.Equal,                "Status", activityStatusId));
esqTotal.Filters.Add(esqTotal.CreateFilter(FilterComparisonType.Exists, "Id", esqActivity));

Но он выдает не совсем то что надо. Мне надо выполнить условие:  

where a.LeadId=l.id

Не могу ни как добиться результата. Может кто нибудь подсказать?