Shuttle.Esb.RabbitMQ 15.0.0

RabbitMQ

PM> Install-Package Shuttle.Esb.RabbitMQ

This RabbitMQ implementation follows the at-least-once delivery mechanism supported by Shuttle.Esb.

If necessary you may want to use an outbox for a store-and-forward solution. By using a transactional outbox such as the Shuttle.Esb.Sql.Queue implementation you could roll back sending of messages on failure.

Installation

If you need to install RabbitMQ you can <a target='_blank' href='https://www.rabbitmq.com/download.html'>follow these instructions</a>.

Configuration

The URI structure is rabbitmq://configuration-name/queue-name.

services.AddRabbitMQ(builder =>
{
    builder.AddOptions("local", new RabbitMQOptions
    {
        Host = "127.0.0.1",
        VirtualHost = "/",
        Port = -1,
        Username = "shuttle",
        Password = "shuttle!",
        PrefetchCount = 25,
        QueueTimeout = TimeSpan.FromMilliseconds(25),
        RequestedHeartbeat = TimeSpan.FromSeconds(30),
        ConnectionCloseTimeout = TimeSpan.FromSeconds(1),
        OperationRetryCount = 3,
        UseBackgroundThreadsForIO = true,
        Priority = 0,
        Persistent = true,
        Durable = true
    });
});

The default JSON settings structure is as follows:

{
  "Shuttle": {
    "RabbitMQ": {
      "local": {
        "Host": "127.0.0.1",
        "VirtualHost": "/",
        "Port": -1,
        "Username": "shuttle",
        "Password": "shuttle!",
        "PrefetchCount": 25,
        "QueueTimeout": "00:00:25",
        "RequestedHeartbeat": "00:00:30",
        "ConnectionCloseTimeout": "00:00:01",
        "OperationRetryCount": 3,
        "UseBackgroundThreadsForIO": true,
        "Priority": 0,
        "Persistent": true,
        "Durable": true
      }
    }
  }
}

Options