Class RabbitMqCommandQueue<TMarker>

Namespace: Savvyio.Extensions.DependencyInjection.RabbitMQ.Commands

Assembly: Savvyio.Extensions.DependencyInjection.RabbitMQ.dll

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

public class RabbitMqCommandQueue<TMarker> : RabbitMqCommandQueue, IDisposable, IAsyncDisposable, IAsyncHealthCheckProvider<IConnection>, IPointToPointChannel<ICommand, TMarker>, IPointToPointChannel<ICommand>, ISender<ICommand, TMarker>, ISender<ICommand>, IReceiver<ICommand, TMarker>, IReceiver<ICommand>, IDependencyInjectionMarker<TMarker>

Type Parameters

TMarker

Inheritance: object

Disposable

AsyncDisposable

RabbitMqMessage

RabbitMqCommandQueue

RabbitMqCommandQueue<TMarker>

Implements: IDisposable

IAsyncDisposable

IAsyncHealthCheckProvider<IConnection>

IPointToPointChannel<ICommand, TMarker>

IPointToPointChannel<ICommand>

ISender<ICommand, TMarker>

ISender<ICommand>

IReceiver<ICommand, TMarker>

IReceiver<ICommand>

IDependencyInjectionMarker<TMarker>

Inherited Members: RabbitMqCommandQueue.SendAsync(IEnumerable<IMessage<ICommand>>, Action<AsyncOptions>)

RabbitMqCommandQueue.ReceiveAsync(Action<AsyncOptions>)

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 RabbitMqCommandQueue registered by AddRabbitMqCommandQueue is the concrete DI-managed command queue; resolve it to access SendAsync and ReceiveAsync.

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

namespace ExampleApp;

public class RabbitMqCommandQueueUsage
{
    private readonly RabbitMqCommandQueue _queue;

    public RabbitMqCommandQueueUsage(RabbitMqCommandQueue queue)
    {
        _queue = queue;
    }

    public IPointToPointChannel<ICommand> AsChannel() => _queue;
}

Constructors

RabbitMqCommandQueue(IMarshaller, RabbitMqCommandQueueOptions<TMarker>)

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

public RabbitMqCommandQueue(IMarshaller marshaller, RabbitMqCommandQueueOptions<TMarker> options)

Parameters

marshaller IMarshaller: The marshaller used for serializing and deserializing messages.
options RabbitMqCommandQueueOptions<TMarker>: The options used to configure the RabbitMQ command queue.

Exceptions

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

Table of Contents