PollyAzureServiceBus 1.0.2

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

Package	Downloads	Description
PollyHealthChecks		ASP.NET Core health checks for Polly v8 circuit breakers — expose circuit-breaker state (Closed, HalfOpen, Open, Isolated) as /health endpoint responses
PollyBackoff		Backoff delay strategies for Polly v8 resilience pipelines
PollyGrpc		Polly v8 resilience interceptor for gRPC
PollyEFCore		Polly v8 resilience pipelines for Entity Framework Core — wrap every EF Core query and SaveChanges with retry, timeout and circuit-breaker via a single AddPollyResilience() call
PollyRabbitMQ		Polly v8 resilience for RabbitMQ.Client v7+ — retry, circuit-breaker, and timeout for IChannel operations, with built-in RabbitMqTransientErrors predicate covering AlreadyClosedException, BrokerUnreachableException, OperationInterruptedException, and ConnectFailureException
PollyMailKit		Polly v8 resilience pipelines for MailKit — retry, timeout, and circuit-breaker for SmtpClient.SendAsync and any MailKit SMTP operation
PollyMassTransit		Polly v8 resilience pipelines for MassTransit — retry, timeout, and circuit-breaker for IBus.Publish and ISendEndpointProvider.Send
PollyOpenAI		Polly v8 resilience for OpenAI and Azure OpenAI API calls
PollyAzureEventHub		Polly v8 resilience pipelines for Azure Event Hubs — retry, timeout, and circuit-breaker for EventHubProducerClient and EventHubConsumerClient
PollySignalR		Polly v8 reconnect policy for SignalR
PollyElasticsearch		Polly v8 resilience pipelines for Elastic.Clients.Elasticsearch 8+ — retry, timeout, and circuit-breaker for any Elasticsearch operation, plus a built-in ElasticTransientErrors predicate covering rate limiting (429), service unavailability (503), gateway timeouts (504), and connection failures
PollyHangfire		Polly v8 resilience pipelines for Hangfire — retry, timeout, and circuit-breaker for IBackgroundJobClient.Enqueue and Schedule
PollySendGrid		Polly v8 resilience pipelines for SendGrid — retry, timeout, and circuit-breaker for ISendGridClient.SendEmailAsync
PollyMediatR		Polly v8 resilience pipelines for MediatR — add retry, timeout, circuit-breaker, rate-limiting, hedging, and chaos engineering to any MediatR request handler with a single line of DI registration
PollyAzureKeyVault		Polly v8 resilience pipelines for Azure Key Vault — retry, timeout, and circuit-breaker for SecretClient, KeyClient, and CertificateClient
PollyAzureQueueStorage		Polly v8 resilience pipelines for Azure Queue Storage — retry, timeout, and circuit-breaker for Azure.Storage.Queues QueueClient
PollyRedis		Polly v8 resilience for StackExchange.Redis
PollyKafka		Polly v8 resilience for Confluent.Kafka — retry, circuit breaker, and timeout for producers and consumers
PollyAzureTableStorage		Polly v8 resilience pipelines for Azure Table Storage — retry, timeout, and circuit-breaker for Azure.Data.Tables TableClient
PollyCaching		A caching resilience strategy for Polly v8 pipelines
PollyChaos		Chaos engineering and fault-injection resilience strategies for Polly v8 pipelines
PollyBulkhead		Bulkhead isolation strategy for Polly v8 resilience pipelines

💼 Need .NET consulting?

The author of this package is available for consulting on Polly v8 resilience, Azure cloud architecture, and clean .NET design.

→ solidqualitysolutions.com · LinkedIn

License

MIT