connection.config

amqp://<User Name>:<Password>@<Host>:<Port>/<vhost>

amqp://mahesh:123456@NDI-LAP-337:5672/

message-consumer.cs

ConnectionFactory _ConnectionFactory = new ConnectionFactory
{
    Uri = ConnectionInstanceManager.InitializeRabbitMqConnectionUri(connectionStringName, true)
};

using (IModel consumerChannel = Connection.CreateModel())
{
    //Declare topic exchange which is durable            
    Channel.ExchangeDeclare("Super-Exchange", ExchangeType.Topic, true);
    
    consumerChannel.QueueDeclare("super-report-processer-queue", _queueProperties.Durable, _queueProperties.Exclusive, 
            _queueProperties.AutoDelete, _queueProperties.Arguments);
    
    //Route key binding with queue
    consumerChannel.QueueBind(queueName, _exchangeProperties.Name, routeKey);
    
    var consumer = new QueueingBasicConsumer(consumerChannel);
    //Consume the message (queue name, noAck, consumer)
    consumerChannel.BasicConsume("super-report-processer-queue", false, consumer);
    
    while (true)
    {
      BasicDeliverEventArgs eventArgs;
      if (consumer.Queue.Dequeue(5000, out eventArgs))
      {
        MessageInfo messageItem = _messageSerializer.ByteArrayToMessageInfo<MessageInfo>(eventArgs.Body);
        
        //process your message
        
        consumerChannel.BasicAck(eventArgs.DeliveryTag, false);
      }
    }
}

message-publisher.cs

ConnectionFactory _ConnectionFactory = new ConnectionFactory
{
    Uri = ConnectionInstanceManager.InitializeRabbitMqConnectionUri(connectionStringName, true)
};

using (Channel = _ConnectionFactory.CreateModel())
{

    byte[] message = this._MessageSerializer.MessageToByteArray(MessageItem, IgnorableSerializerContractResolver);


    //Declare topic exchange which is durable            
    Channel.ExchangeDeclare("Super-Exchange", ExchangeType.Topic, true);


    //Message property
    IBasicProperties _BasicProperties = new BasicProperties
    {
        ContentEncoding = "utf8",
        ContentType = "application/json",
        Timestamp = new AmqpTimestamp(GetEpochTimeStamp()),
    };
    _BasicProperties.SetPersistent(true);
    
    //Publisher confirm
    Channel.ConfirmSelect();
    
    Channel.BasicPublish(_MessageExchangeProperties.Name, MessageItem.RouteKey, basicProperties, message);
    
    //Wait for confirmation from RabbitMQ
    Channel.WaitForConfirmsOrDie(TimeSpan.FromMilliseconds(_MessageExchangeProperties.WaitForConfirmsTimeOut));
    
}

rabbitmqctl.bat

rabbitmq-service.bat start

rabbitmqctl stop

rabbitmqctl stop_app

rabbitmqctl start_app