laget.Azure.ServiceBus 1.1.27

laget.Azure.ServiceBus

A generic implementation of Microsoft.Azure.ServiceBus, the next generation Azure Service Bus .NET Standard client library that focuses on queues & topics. For more information about Service Bus...

Usage

public class SomeClass : IHostedService
{
    readonly TopicReceiver _receiver;

    public SomeClass(IConfiguration configuration)
    {
        _receiver = new TopicReceiver(configuration.GetValue<string>("ServiceBus:Url")
                .Replace("{name}", configuration.GetValue<string>("ServiceBus:QueueService:Name"))
                .Replace("{key}", configuration.GetValue<string>("ServiceBus:QueueService:QueueKey")),
            new TopicOptions
            {
                TopicName = "queue",
                SubscriptionName = "queue-service",
                ReceiveMode = ReceiveMode.PeekLock
            });
    }


    public async Task StartAsync(CancellationToken ct)
    {
        await Task.Run(() =>
        {
            _receiver.Register((message, _) =>
            {
                var queue = message.Deserialize<QueueMessage>();

                _handler.Handle(queue);

                return Task.CompletedTask;
            }, ExceptionHandler);
        }, ct);
    }

    public Task StopAsync(CancellationToken cancellationToken)
    {
        return Task.CompletedTask;
    }

    Task ExceptionHandler(ExceptionReceivedEventArgs ex)
    {
        // Log here

        return Task.CompletedTask;
    }
}