_channel = Factory.CreateConnection().CreateModel();
_channel.QueueDeclare
(
  queue: QueueName,
  durable: true,
  exclusive: false,
  autoDelete: false,
  arguments: null
);

_consumer = new EventingBasicConsumer(_channel);
_consumer.Received += ConsumerOnReceived;
_channel.BasicConsume(QueueName, false, _consumer);

_channel.BasicPublish
(
    exchange: exchangeName,
    routingKey: routingKey,
    basicProperties: null,
    body: Encoding.UTF8.GetBytes(message)
);