Blog.Arcus.Messaging.CircuitBreakerExample.cs

using Arcus.Messaging.Abstractions.ServiceBus.MessageHandling;
using Arcus.Messaging.Pumps.Abstractions.Resiliency;

public class OrderMessageHandler : IAzureServiceBusMessageHandler<Order>
{
    private readonly IMessagePumpCircuitBreaker _circuitBreaker;

    public OrderMessageHandler(IMessagePumpCircuitBreaker circuitBreaker)
    {
        _circuitBreaker = circuitBreaker;
    }

    public async Task ProcessMessageAsync(Order message, AzureServiceBusMessageContext messageContext, ...)
    {
        // Determine whether your dependent system is healthy...

        // If not, call the circuit breaker, processing will be halted temporarily.
        await _circuitBreaker.PauseMessageProcessingAsync(messageContext.JobId);
    }
}