AugusteVN.Azure.ServiceBus 1.0.3

Azure Service Bus

Publishing messages to- & receiving messages from the Azure Service Bus.

This package contains wrapper- & helper functions for the official Azure.Messaging.ServiceBus NuGet package.

Contains:

• SenderClient to send a message to a topic.
• ReceiverClient to receive messages from a topic subscription.

Configuration

appsettings.json

{
  "ServiceBusConfig": {
    "ConnectionString": "<to-fill>",
    "TopicName": "<to-fill>",
    "SubscriptionName": "<optional-only-needed-for-receiving>"
  }
}

Program.cs

builder.Services
    .AddOptions<ServiceBusConfig>()
    .BindConfiguration(nameof(ServiceBusConfig));

services.AddSingleton<ISenderClient, SenderClient>();
services.AddSingleton<IReceiverClient, ReceiverClient>();

// Or initialize an instance of either.

var sender = new SenderClient(
    new ServiceBusConfig {
        ConnectionString = "<to-fill>",
        TopicName = "<to-fill>"
    });

var receiver = new ReceiverClient(
    new ServiceBusConfig {
        ConnectionString = "<to-fill>",
        TopicName = "<to-fill>",
        SubscriptionName = "<to-fill>"
    });

Send Message

Program.cs

app.MapPost("/", async (ISenderClient sender) => {
    
    var data = new { Foo = "bar" };
    var customProperties = new Dictionary<string, object> {{ "foo", "bar" }};
    
    await sender.SendAsync(data, customProperties);
    
    // Or use the overload and construct your own 'ServiceBusMessage'.
    await sender.SendAsync(new ServiceBusMessage(body: data) {
        CorrelationId = "",
        ApplicationProperties = customProperties,
        ...
    });
    
    return Results.NoContent();
});

Receive Message

Program.cs

app.MapPost("/", async (IReceiverClient receiver) => {
    
    var message = await receiver.ReceiveMessageAsync(
        maxWaitTime: TimeSpan.FromMinutes(5));
    
    if (message != null) {
        await receiver.CompleteMessageAsync(message);
    }
    
    return Results.NoContent();
});

Receive Multiple Messages

Program.cs

app.MapPost("/", async (IReceiverClient receiver) => {
    
    var messages = await receiver.ReceiveMessagesAsync(
        maxMessages: 300,
        maxWaitTime: TimeSpan.FromMinutes(5));
    
    foreach(var message in messages) {
        var isWantedMessage = message.ApplicationProperties["foo"]?.ToString() == "bar";
        if (!isWantedMessage) continue;

        var messageBody = receiver.ParseMessageBody<object>(message);
        
        ...
        
        var isSuccess = await DoStuff(messageBody);
        if (!isSuccess) continue;
            
        await receiver.CompleteMessageAsync(message);    
    }
    
    return Results.NoContent();
});

To see it in action, watch: Azure Service Bus Messaging in C# .NET