PollyAzureServiceBus 1.0.0

PollyAzureServiceBus

Polly v8 resilience for Azure Service Bus — automatic retry, circuit breaker, and per-operation timeout for sending and receiving messages. Drop-in wrappers for ServiceBusSender and ServiceBusReceiver, no configuration changes required.

Why PollyAzureServiceBus?

The Azure Service Bus SDK ships with its own retry policy, but it only covers a subset of transient failures and cannot be composed with your broader application resilience strategy. PollyAzureServiceBus gives you the full power of Polly v8 — exponential back-off with jitter, circuit breaker isolation, per-call timeouts, and telemetry hooks — applied consistently to every send and receive operation.

Installation

dotnet add package PollyAzureServiceBus

Quick Start

Sender

var client = new ServiceBusClient(connectionString);

// Extension method on ServiceBusClient
var sender = client.CreateResilientSender("my-queue", o =>
{
    o.MaxRetries    = 3;
    o.BaseDelay     = TimeSpan.FromMilliseconds(500);
    o.OperationTimeout = TimeSpan.FromSeconds(30);
});

await sender.SendMessageAsync(new ServiceBusMessage("Hello, World!"));

Receiver

var receiver = client.CreateResilientReceiver("my-queue");

// or for topic subscriptions:
var receiver = client.CreateResilientReceiver("my-topic", "my-subscription");

var message = await receiver.ReceiveMessageAsync();
if (message is not null)
{
    // process message...
    await receiver.CompleteMessageAsync(message);
}

With Dependency Injection

// Program.cs
builder.Services.AddResilientServiceBusSender(
    connectionString: Environment.GetEnvironmentVariable("SERVICE_BUS_CONNECTION")!,
    queueOrTopicName: "orders",
    configure: o =>
    {
        o.MaxRetries        = 3;
        o.OperationTimeout  = TimeSpan.FromSeconds(30);
    });

builder.Services.AddResilientServiceBusReceiver(
    connectionString: Environment.GetEnvironmentVariable("SERVICE_BUS_CONNECTION")!,
    queueName: "orders");

// Inject ResilientServiceBusSender / ResilientServiceBusReceiver

With Managed Identity (DefaultAzureCredential)

using Azure.Identity;

var credential = new DefaultAzureCredential();
var client = new ServiceBusClient("mynamespace.servicebus.windows.net", credential);
var sender = client.CreateResilientSender("my-queue");

Configuration

var options = new PollyServiceBusOptions
{
    // Retry
    MaxRetries = 3,                              // 0 = no retry
    BaseDelay  = TimeSpan.FromMilliseconds(500), // exponential base
    MaxDelay   = TimeSpan.FromSeconds(30),

    // Circuit breaker
    CircuitBreakerFailureRatio      = 0.5,
    CircuitBreakerMinimumThroughput = 10,
    CircuitBreakerSamplingDuration  = TimeSpan.FromSeconds(30),
    CircuitBreakerBreakDuration     = TimeSpan.FromSeconds(5),

    // Timeout
    OperationTimeout = TimeSpan.FromSeconds(30),

    // Which failure reasons are treated as transient (eligible for retry)
    TransientFailureReasons = new HashSet<ServiceBusFailureReason>
    {
        ServiceBusFailureReason.ServiceCommunicationProblem,
        ServiceBusFailureReason.ServiceTimeout,
        ServiceBusFailureReason.ServiceBusy,
        ServiceBusFailureReason.GeneralError,
    },
};

API Reference

ResilientServiceBusSender

ResilientServiceBusReceiver

Error Handling

Non-transient ServiceBusExceptions (e.g. MessagingEntityNotFound, MessageSizeExceeded) are rethrown as-is. After retries are exhausted the last exception is a TransientServiceBusException wrapping the original:

try
{
    await sender.SendMessageAsync(message);
}
catch (TransientServiceBusException ex)
{
    // All retries failed
    Console.WriteLine($"Service Bus failure: {ex.Reason} — {ex.ServiceBusException.Message}");
}
catch (BrokenCircuitException)
{
    // Circuit is open — fail fast without hitting the broker
}
catch (TimeoutRejectedException)
{
    // Operation exceeded OperationTimeout
}

Resilience Pipeline Order

Retry → Circuit Breaker → Timeout → Service Bus operation

Related Packages

License

MIT