Class AzureEventBus<TMarker>

Namespace: Savvyio.Extensions.DependencyInjection.QueueStorage.EventDriven

Assembly: Savvyio.Extensions.DependencyInjection.QueueStorage.dll

Provides a default implementation of the AzureEventBus class that is optimized for Dependency Injection.

public class AzureEventBus<TMarker> : AzureEventBus, IHealthCheckProvider<Uri>, IPublishSubscribeChannel<IIntegrationEvent, TMarker>, IPublishSubscribeChannel<IIntegrationEvent>, IPublisher<IIntegrationEvent, TMarker>, IPublisher<IIntegrationEvent>, ISubscriber<IIntegrationEvent, TMarker>, ISubscriber<IIntegrationEvent>, IDependencyInjectionMarker<TMarker>

Type Parameters

TMarker

Inheritance: object

AzureQueue<IIntegrationEvent>

AzureEventBus

AzureEventBus<TMarker>

Implements: IHealthCheckProvider<Uri>

IPublishSubscribeChannel<IIntegrationEvent, TMarker>

IPublishSubscribeChannel<IIntegrationEvent>

IPublisher<IIntegrationEvent, TMarker>

IPublisher<IIntegrationEvent>

ISubscriber<IIntegrationEvent, TMarker>

ISubscriber<IIntegrationEvent>

IDependencyInjectionMarker<TMarker>

Inherited Members: AzureEventBus.CloudEventTypeExtensionAttribute

AzureEventBus.PublishAsync(IMessage<IIntegrationEvent>, Action<AsyncOptions>)

AzureEventBus.SubscribeAsync(Func<IMessage<IIntegrationEvent>, CancellationToken, Task>, Action<SubscribeAsyncOptions>)

AzureEventBus.GetHealthCheckTarget()

AzureQueue<IIntegrationEvent>.SendMessageAsync(IEnumerable<IMessage<IIntegrationEvent>>, Action<AsyncOptions>)

AzureQueue<IIntegrationEvent>.ReceiveMessagesAsync(Action<AsyncOptions>)

Examples

AzureEventBus<TMarker> is the DI-registered Azure Queue Storage event bus with a lifetime marker. It implements IPublishSubscribeChannel<IIntegrationEvent>. Inject it to subscribe to and publish integration events through an Azure Storage queue.

using System;
using System.Threading.Tasks;
using Savvyio.EventDriven;
using Savvyio.Extensions.QueueStorage.EventDriven;
using Savvyio.Messaging;

namespace ExampleApp;

public sealed class EventListener
{
    public static async Task SubscribeAsync(AzureEventBus bus)
    {
        await bus.SubscribeAsync(async (message, token) =>
        {
            Console.WriteLine($"Received event: {message.Type}");
            await Task.CompletedTask;
        }).ConfigureAwait(false);
    }
}

Constructors

AzureEventBus(IMarshaller, AzureQueueOptions<TMarker>, AzureEventBusOptions<TMarker>)

Initializes a new instance of the AzureEventBus<TMarker> class.

public AzureEventBus(IMarshaller marshaller, AzureQueueOptions<TMarker> azureQueueOptions, AzureEventBusOptions<TMarker> azureEventBusOptions)

Parameters

marshaller IMarshaller: The IMarshaller that is used when converting IIntegrationEvent implementations to messages.
azureQueueOptions AzureQueueOptions<TMarker>: The AzureQueueOptions<TMarker> used to configure this instance.
azureEventBusOptions AzureEventBusOptions<TMarker>: The AzureEventBusOptions<TMarker> used to configure this instance.

Exceptions

ArgumentNullException: marshaller cannot be null - or - azureEventBusOptions cannot be null.
ArgumentException: azureEventBusOptions are not in a valid state.

Table of Contents