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>)

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.

See Also

AzureEventBus

IPublishSubscribeChannel<TRequest, TMarker>