Class RabbitMqEventBus<TMarker>

Namespace: Savvyio.Extensions.DependencyInjection.RabbitMQ.EventDriven

Assembly: Savvyio.Extensions.DependencyInjection.RabbitMQ.dll

Provides a default implementation of the RabbitMqMessage class for messages holding an IIntegrationEvent implementation.

public class RabbitMqEventBus<TMarker> : RabbitMqEventBus, IDisposable, IAsyncDisposable, IAsyncHealthCheckProvider<IConnection>, IPublishSubscribeChannel<IIntegrationEvent, TMarker>, IPublishSubscribeChannel<IIntegrationEvent>, IPublisher<IIntegrationEvent, TMarker>, IPublisher<IIntegrationEvent>, ISubscriber<IIntegrationEvent, TMarker>, ISubscriber<IIntegrationEvent>, IDependencyInjectionMarker<TMarker>

Type Parameters

TMarker

Inheritance: object

Disposable

AsyncDisposable

RabbitMqMessage

RabbitMqEventBus

RabbitMqEventBus<TMarker>

Implements: IDisposable

IAsyncDisposable

IAsyncHealthCheckProvider<IConnection>

IPublishSubscribeChannel<IIntegrationEvent, TMarker>

IPublishSubscribeChannel<IIntegrationEvent>

IPublisher<IIntegrationEvent, TMarker>

IPublisher<IIntegrationEvent>

ISubscriber<IIntegrationEvent, TMarker>

ISubscriber<IIntegrationEvent>

IDependencyInjectionMarker<TMarker>

Inherited Members: RabbitMqEventBus.PublishAsync(IMessage<IIntegrationEvent>, Action<AsyncOptions>)

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

RabbitMqMessage.MessageType

RabbitMqMessage.RabbitMqFactory

RabbitMqMessage.EnsureConnectivityAsync(CancellationToken)

RabbitMqMessage.RabbitMqConnection

RabbitMqMessage.RabbitMqChannel

RabbitMqMessage.Marshaller

RabbitMqMessage.OnDisposeManagedResourcesAsync()

RabbitMqMessage.GetHealthCheckTargetAsync(CancellationToken)

AsyncDisposable.OnDisposeManagedResources()

AsyncDisposable.DisposeAsync()

Disposable.OnDisposeUnmanagedResources()

Disposable.Dispose()

Disposable.Dispose(bool)

Disposable.Disposed

Examples

The RabbitMqEventBus registered by AddRabbitMqEventBus is the concrete DI-managed event bus; resolve it to access PublishAsync and SubscribeAsync.

using System;
using Microsoft.Extensions.DependencyInjection;
using Savvyio.EventDriven;
using Savvyio.Extensions.RabbitMQ.EventDriven;
using Savvyio.Messaging;

namespace ExampleApp;

public class RabbitMqEventBusUsage
{
    private readonly RabbitMqEventBus _bus;

    public RabbitMqEventBusUsage(RabbitMqEventBus bus)
    {
        _bus = bus;
    }

    public IPublishSubscribeChannel<IIntegrationEvent> AsChannel() => _bus;
}

Constructors

RabbitMqEventBus(IMarshaller, RabbitMqEventBusOptions<TMarker>)

Initializes a new instance of the RabbitMqEventBus class.

public RabbitMqEventBus(IMarshaller marshaller, RabbitMqEventBusOptions<TMarker> options)

Parameters

marshaller IMarshaller: The marshaller used for serializing and deserializing messages.
options RabbitMqEventBusOptions<TMarker>: The options used to configure the RabbitMQ event bus.

Exceptions

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

Table of Contents