PollyRabbitMQ 1.0.1

PollyRabbitMQ

Polly v8 resilience for RabbitMQ.Client v7+ — retry, circuit-breaker, and timeout for IChannel operations, with a built-in RabbitMqTransientErrors predicate covering the most common RabbitMQ transient exceptions. Includes automatic channel recreation between retries so AlreadyClosedException never kills your publisher.

// Before — crashes on broker restart
await channel.BasicPublishAsync("orders", "order.placed", body: payload);

// After — retry + channel recreation + circuit breaker
var resilient = await connection.CreateResilientChannelAsync(options =>
{
    options.MaxRetries = 3;
    options.RecreateChannelOnFailure = true; // rebuild channel between retries ✔
});

await resilient.BasicPublishAsync("orders", "order.placed", body: payload);

Installation

dotnet add package PollyRabbitMQ

Targets net6.0, net8.0, and net9.0. Dependencies: Polly.Core 8.*, RabbitMQ.Client 7.*, Microsoft.Extensions.DependencyInjection.Abstractions 8.*

RabbitMqTransientErrors — the key feature

PollyRabbitMQ ships RabbitMqTransientErrors.IsTransient — a pre-built PredicateBuilder covering the four most common transient RabbitMQ exceptions:

new RetryStrategyOptions
{
    MaxRetryAttempts = 3,
    ShouldHandle = RabbitMqTransientErrors.IsTransient, // built-in ✔
}

Covered exceptions

The critical one: AlreadyClosedException is thrown when the broker closes a channel while your app is publishing. Without retry, this crashes your publisher. With PollyRabbitMQ and RecreateChannelOnFailure = true, the channel is rebuilt transparently before each retry.

Quick start

Option 1 — Options-based (recommended)

using PollyRabbitMQ;

var factory = new ConnectionFactory { HostName = "localhost" };
await using var connection = await factory.CreateConnectionAsync();

await using var resilient = await connection.CreateResilientChannelAsync(options =>
{
    options.MaxRetries              = 3;
    options.BaseDelay               = TimeSpan.FromMilliseconds(500);
    options.MaxDelay                = TimeSpan.FromSeconds(30);
    options.OperationTimeout        = TimeSpan.FromSeconds(15);
    options.RecreateChannelOnFailure = true;
    options.CircuitBreakerFailureRatio      = 0.5;
    options.CircuitBreakerMinimumThroughput = 10;
    options.CircuitBreakerBreakDuration     = TimeSpan.FromSeconds(5);
});

// Publish
await resilient.BasicPublishAsync("orders", "order.placed", body: payload);

// Consume single message
var message = await resilient.BasicGetAsync("order-queue", autoAck: false);
if (message is not null)
{
    // Process...
    await resilient.BasicAckAsync(message.DeliveryTag);
}

// Topology
await resilient.QueueDeclareAsync("order-queue", durable: true);
await resilient.ExchangeDeclareAsync("orders", ExchangeType.Direct, durable: true);

Option 2 — Dependency injection

// Program.cs
builder.Services.AddResilientRabbitMqChannel(
    configureFactory: factory =>
    {
        factory.HostName = "localhost";
        factory.UserName = "guest";
        factory.Password = "guest";
    },
    configureOptions: options =>
    {
        options.MaxRetries = 3;
        options.RecreateChannelOnFailure = true;
    });

// Publisher
public class OrderPublisher(ResilientChannel channel)
{
    public Task PublishAsync(ReadOnlyMemory<byte> payload, CancellationToken ct = default) =>
        channel.BasicPublishAsync("orders", "order.placed", payload, cancellationToken: ct);
}

Supported operations

How channel recreation works

When RecreateChannelOnFailure = true (default) and a transient error occurs, ResilientChannel will:

1. Detect the failure (catch AlreadyClosedException etc.)
2. Check if the current channel is closed
3. Create a new IChannel from the same connection before the next retry attempt
4. Transparently continue — your code doesn't change

This is critical for long-running publishers that survive broker restarts.

Pipeline order

[Timeout] → [Retry + channel recreation] → [Circuit Breaker] → [RabbitMQ broker]

Related packages

Package	Downloads	Description
PollyAzureServiceBus		Polly v8 resilience for Azure Service Bus
PollyGrpc		Polly v8 resilience for gRPC .NET with GrpcTransientErrors predicate
PollyRedis		Polly v8 resilience for StackExchange.Redis
PollyNpgsql		Polly v8 resilience for Npgsql (PostgreSQL) with PostgresTransientErrors predicate
PollySqlClient		Polly v8 resilience for SQL Server and Azure SQL
PollyCosmosDb		Polly v8 resilience for Azure Cosmos DB
PollyMongo		Polly v8 resilience for MongoDB.Driver
PollyEFCore		Polly v8 resilience for Entity Framework Core
PollyDapper		Polly v8 resilience for Dapper
PollyMediatR		Polly v8 resilience for MediatR
PollyOpenAI		Polly v8 resilience for OpenAI and Azure OpenAI
PollyHealthChecks		ASP.NET Core health checks for Polly v8 circuit breakers
PollyBackoff		Jitter, linear & custom backoff for Polly v8 retry

License

MIT