Setting the endpoint for receiving messages

DefaultRabbitMQAdapter.cs

public void StartConsuming()
{
    consumerChannel = connection.CreateModel();
    consumerChannel.ExchangeDeclare(COMMAND_EXCHANGE_NAME, ExchangeType.Direct);
    consumerChannel.ExchangeDeclare(EVENT_EXCHANGE_NAME, ExchangeType.Fanout);

    var queue = consumerChannel.QueueDeclare(queue: queueName);
    consumerChannel.QueueBind(queue, COMMAND_EXCHANGE_NAME, routingKey: queueName);
    consumerChannel.QueueBind(queue, EVENT_EXCHANGE_NAME, routingKey: queueName);

    var consumer = new EventingBasicConsumer(consumerChannel);

    consumerChannel.BasicConsume(queue: queueName, autoAck: true, consumer: consumer);

    consumer.Received += (model, ea) => {
        var messageBody = ea.Body.ToArray().GetPayloadString();
        var args = JsonConvert.DeserializeObject<MessageReceivedEventArgs>(messageBody); 
        MessageReceived.Invoke(args);
    };
}