Shuttle.Hopper.RabbitMQ 21.0.2

Shuttle.Hopper.RabbitMQ

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

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

Installation

dotnet add package Shuttle.Hopper.RabbitMQ

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.AddHopper()
    .UseRabbitMQ(builder =>
    {
        builder.Configure("local", options =>
        {
            options.Host = "127.0.0.1";
            options.VirtualHost = "/";
            options.Port = -1;
            options.Username = "shuttle";
            options.Password = "shuttle!";
            options.PrefetchCount = 25;
            options.QueueTimeout = TimeSpan.FromSeconds(1);
            options.RequestedHeartbeat = TimeSpan.FromSeconds(30);
            options.ConnectionCloseTimeout = TimeSpan.FromSeconds(1);
            options.OperationRetryCount = 3;
            options.Priority = 0;
            options.Persistent = true;
            options.Durable = true;
        });
    });

You can also provide a pre-configured ConnectionFactory instance:

services.AddHopper()
    .UseRabbitMQ(builder =>
    {
        builder.Configure("local", options =>
        {
            options.ConnectionFactory = new RabbitMQ.Client.ConnectionFactory
            {
                HostName = "127.0.0.1",
                VirtualHost = "/",
                UserName = "shuttle",
                Password = "shuttle!"
            };
            options.PrefetchCount = 25;
            options.QueueTimeout = TimeSpan.FromSeconds(1);
            options.ConnectionCloseTimeout = TimeSpan.FromSeconds(1);
            options.OperationRetryCount = 3;
            options.Priority = 0;
            options.Persistent = true;
            options.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:01",
        "RequestedHeartbeat": "00:00:30",
        "ConnectionCloseTimeout": "00:00:01",
        "OperationRetryCount": 3,
        "Priority": 0,
        "Persistent": true,
        "Durable": true
      }
    }
  }
}

Options