Azure Bus Depot

Motivation

A compact, opinioned but extensible .Net Standard SDK for Azure Service Bus which aims to tackle the cross-cutting concerns of:

• Deserialisation: Extensible IMessageSerialiser to derive an instance of your TMessage from a Message with built-in JSON deserialisation using JsonMessageSerialiser
• Handler dispatching: Extensible IMessageProcessorDispatcher for dispatching your IMessageHandler implementation with built-in property based dispatching using MessagePropertyBasedDispatcher
• Logging: Uses ILogger methods from Microsoft.Extensions.Logging with built-in Application Insights tracing
• Telemetry: Extensible IInstrumentor to measure elapsed handling with built-in Application Insights metric tracking
• Exception handling: Handles common problems with message handling by abandoning or dead-lettering messages with enriched properties explaining the outcome

Getting Started

1. Install the package AzureBusDepot from nuget
2. Define implementations of IMessageHandler<TMessage> for your message types (see sample)
3. Define implementations of IEndpointHandlingConfig for every Azure Service Bus endpoint you want to to listen to. As a consumer it is a bit of work but these unique config types are required to play nice with dependency injection and reduces a whole lot of boilerplate bootstrapping code.

Single Message Type expected from a Queue / Topic Subscription

Add the following to ConfigureServices((hostContext, services) =>{...}) of a Generic HostBuilder.

services
    .AddAzureBusDepot<JsonMessageSerialiser>()
    .ConfigureSingleMessageTypeListener<MyEndpointHandlingConfig, MyEvent, MyEventHandler>(endpointConfig)
    .AddApplicationInsights(appInsightsOptions);

Multiple Message Types expected from a Queue / Topic Subscription

Add the following to ConfigureServices((hostContext, services) =>{...}) of a Generic HostBuilder.

services
    .AddAzureBusDepot<JsonMessageSerialiser>()
    .ConfigureMessageListenerWithPropertyBasedDispatcher(
        endpointConfig, "NServiceBus.EnclosedMessageType")
    .AddMessageHandler<MyEvent, MyEventHandler>()
    .AddMessageHandler<MyOtherEvent, MyOtherEventHandler>()
    .AddApplicationInsights(appInsightsOptions);

Samples

Samples can be found under the samples folder.

Contributing

Please see the contributing document.