SearchController.cs

private List<SearchResult> CollectResults(Dictionary<string, string> queryServices)
{
    List<SearchResult> results = new List<SearchResult>();

    int pendingResultsCount = queryServices.Count;
    DateTime start = DateTime.Now;

    while (pendingResultsCount > 0 && (DateTime.Now - start).TotalSeconds < 10 )
    {
        var returnedSingle = _runtime.ReceiveSingle<SearchResult>();

        if (returnedSingle != null)
        {
            var result = returnedSingle.Data.Payload;

            if (queryServices[result.Service] == _runtime.QueueServer.LastCorrelationId)
            {
                results.Add(result);
                --pendingResultsCount;
            }
        }
    }

    return results;
}