SearchController.cs

static void Main(string[] args)
{
    Runtime runtime = new Runtime(QueueMode.Server | QueueMode.Client);

    ILoggerFactory loggerFactory = new LoggerFactory()
        .AddDebug(LogLevel.Debug)                
        .AddNesterLog(LogLevel.Debug);
    ILogger logger = loggerFactory.CreateLogger<Bitbucket>();

    BitbucketRepository repo = new BitbucketRepository(runtime, logger);

    var consumer = runtime.QueueServer
        .CreateConsumer();

    consumer.Received += async (model, ea) =>
    {
        // 1. Read the next received request

        var body = ea.Body;
        var props = ea.BasicProperties; 

        string response = null;

        try
        {
            if (props.Headers != null && props.Headers.ContainsKey("Type"))
            {
                // 2. Check if a search request was received

                string messageType = Encoding.UTF8.GetString(
                    props.Headers["Type"] as byte[]);

                if (messageType == typeof(SearchQuery).ToString())
                {
                    var message = Encoding.UTF8.GetString(body);
                    var searchsearch = JsonConvert.DeserializeObject<SearchQuery>(message);

                    // 3. Perform a search and return the result

                    SearchResult result = await repo.SearchAsync(search);

                    // 4. Create a response to send back

                    response = ResultFactory.CreateSingle<SearchResult>(
                        result, 0, "Success");
                }
            }
        }
        catch (Exception e)
        {
            logger.LogError(" [.] " + e.Message);
            response = ResultFactory.Create(
                -1, "Failed", e.Message);
        }
        finally
        {
            // 5. Send back the result to the handler

            var responseBytes = Encoding.UTF8.GetBytes(response);
            runtime.QueueServer.DefaultChannel.Publish(
                props.ReplyTo, responseBytes,
                typeof(Result<SearchResult>), props.CorrelationId);
        }
    };
}