AzureEventBus<TMarker> Class

Definition

Namespace

Savvyio.Extensions.DependencyInjection.QueueStorage.EventDriven

Assemblies

Savvyio.Extensions.DependencyInjection.QueueStorage.dll

Source

src/Savvyio.Extensions.DependencyInjection.QueueStorage/EventDriven/AzureEventBus.cs

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

Name	Description
AzureEventBus(IMarshaller, AzureQueueOptions<TMarker>, AzureEventBusOptions<TMarker>)	Initializes a new instance of the AzureEventBus<TMarker> class.

See Also

AzureEventBus

IPublishSubscribeChannel<TRequest, TMarker>