PollyRabbitMQ 1.0.0

PollyRabbitMQ

PollyRabbitMQ wraps RabbitMQ.Client v7 channels with a Polly v8 resilience pipeline — retry, circuit breaker, and timeout — so your messaging code handles transient broker failures transparently.

Features

• 🔁 Retry with exponential back-off + jitter on transient RabbitMQ exceptions
• ⚡ Circuit Breaker to stop hammering a degraded broker
• ⏱️ Timeout per operation
• 🔄 Optional channel recreation between retries when the broker closes the channel
• 🧩 Works with any IChannel from RabbitMQ.Client 7+
• 💉 Dependency Injection via IServiceCollection extensions

Installation

dotnet add package PollyRabbitMQ

Quick Start

using PollyRabbitMQ;
using RabbitMQ.Client;

// Create a connection the normal way
var factory = new ConnectionFactory { HostName = "localhost" };
await using var connection = await factory.CreateConnectionAsync();

// Wrap a channel with Polly resilience
var resilientChannel = await connection.CreateResilientChannelAsync();

// Declare a queue
await resilientChannel.QueueDeclareAsync("my-queue");

// Publish a message — retried automatically on transient failures
var body = Encoding.UTF8.GetBytes("Hello, World!");
await resilientChannel.BasicPublishAsync("", "my-queue", body);

// Consume a message
var result = await resilientChannel.BasicGetAsync("my-queue");
if (result is not null)
{
    Console.WriteLine(Encoding.UTF8.GetString(result.Body.Span));
    await resilientChannel.BasicAckAsync(result.DeliveryTag);
}

Dependency Injection

builder.Services.AddResilientRabbitMqChannel(connection, options =>
{
    options.MaxRetries = 5;
    options.BaseDelay = TimeSpan.FromMilliseconds(200);
    options.MaxDelay = TimeSpan.FromSeconds(30);
    options.OperationTimeout = TimeSpan.FromSeconds(10);
    options.CircuitBreakerFailureRatio = 0.5;
    options.CircuitBreakerMinimumThroughput = 5;
    options.CircuitBreakerBreakDuration = TimeSpan.FromSeconds(30);
    options.RecreateChannelOnFailure = true;
});

// Inject ResilientChannel into your service
public class MyConsumer(ResilientChannel channel) { ... }

Options

Transient Exceptions

The following RabbitMQ exceptions are treated as transient and trigger retry:

• AlreadyClosedException — channel closed by broker
• OperationInterruptedException — operation interrupted
• BrokerUnreachableException — broker temporarily unreachable
• ConnectFailureException — initial connection failed

Non-transient exceptions propagate immediately without retry.

Channel Recreation

When RecreateChannelOnFailure = true and a channel factory is supplied, the channel is recreated between retries:

var channel = await connection.CreateResilientChannelAsync(
    options: new PollyRabbitMqOptions { RecreateChannelOnFailure = true },
    channelFactory: ct => connection.CreateChannelAsync(cancellationToken: ct));

Related Packages

License

MIT