Class NatsCommandQueue<TMarker>

Namespace

Savvyio.Extensions.DependencyInjection.NATS.Commands

Assembly

Savvyio.Extensions.DependencyInjection.NATS.dll

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

public class NatsCommandQueue<TMarker> : NatsCommandQueue, IDisposable, IAsyncDisposable, IHealthCheckProvider<INatsConnection>, IPointToPointChannel<ICommand, TMarker>, IPointToPointChannel<ICommand>, ISender<ICommand, TMarker>, ISender<ICommand>, IReceiver<ICommand, TMarker>, IReceiver<ICommand>, IDependencyInjectionMarker<TMarker>

Type Parameters

TMarker

Inheritance

object

Disposable

AsyncDisposable

NatsMessage

NatsCommandQueue

NatsCommandQueue<TMarker>

Implements

IDisposable

IAsyncDisposable

IHealthCheckProvider<INatsConnection>

IPointToPointChannel<ICommand, TMarker>

IPointToPointChannel<ICommand>

ISender<ICommand, TMarker>

ISender<ICommand>

IReceiver<ICommand, TMarker>

IReceiver<ICommand>

IDependencyInjectionMarker<TMarker>

Inherited Members

NatsCommandQueue.SendAsync(IEnumerable<IMessage<ICommand>>, Action<AsyncOptions>)

NatsCommandQueue.ReceiveAsync(Action<AsyncOptions>)

NatsMessage.NatsClient

NatsMessage.Marshaller

NatsMessage.OnDisposeManagedResourcesAsync()

NatsMessage.GetHealthCheckTarget()

AsyncDisposable.OnDisposeManagedResources()

AsyncDisposable.DisposeAsync()

Disposable.OnDisposeUnmanagedResources()

Disposable.Dispose()

Disposable.Dispose(bool)

Disposable.Disposed

Constructors

NatsCommandQueue(IMarshaller, NatsCommandQueueOptions<TMarker>)

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

public NatsCommandQueue(IMarshaller marshaller, NatsCommandQueueOptions<TMarker> options)

Parameters

marshaller IMarshaller

The marshaller used for serializing and deserializing messages.

options NatsCommandQueueOptions<TMarker>

The options used to configure the NATS command queue.

Exceptions

ArgumentNullException

marshaller cannot be null -or- options cannot be null.

ArgumentException

options are not in a valid state.

See Also

NatsCommandQueue<TMarker>

IPointToPointChannel<TRequest, TMarker>