AzureCommandQueue<TMarker> Class

Definition

Namespace

Savvyio.Extensions.DependencyInjection.QueueStorage.Commands

Assemblies

Savvyio.Extensions.DependencyInjection.QueueStorage.dll

Source

src/Savvyio.Extensions.DependencyInjection.QueueStorage/Commands/AzureCommandQueue.cs

Provides a default implementation of the AzureCommandQueue class that is optimized for Dependency Injection.

public class AzureCommandQueue<TMarker> : AzureCommandQueue, IHealthCheckProvider<QueueServiceClient>, IPointToPointChannel<ICommand, TMarker>, IPointToPointChannel<ICommand>, ISender<ICommand, TMarker>, ISender<ICommand>, IReceiver<ICommand, TMarker>, IReceiver<ICommand>, IDependencyInjectionMarker<TMarker>

Type Parameters

TMarker

Inheritance

object

AzureQueue<ICommand>

AzureCommandQueue

AzureCommandQueue<TMarker>

Implements

IHealthCheckProvider<QueueServiceClient>

IPointToPointChannel<ICommand, TMarker>

IPointToPointChannel<ICommand>

ISender<ICommand, TMarker>

ISender<ICommand>

IReceiver<ICommand, TMarker>

IReceiver<ICommand>

IDependencyInjectionMarker<TMarker>

Inherited Members

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

AzureCommandQueue.ReceiveAsync(Action<AsyncOptions>)

AzureCommandQueue.GetHealthCheckTarget()

AzureQueue<ICommand>.SendMessageAsync(IEnumerable<IMessage<ICommand>>, Action<AsyncOptions>)

AzureQueue<ICommand>.ReceiveMessagesAsync(Action<AsyncOptions>)

Examples

AzureCommandQueue<TMarker> is the DI-registered Azure Queue Storage command queue with a lifetime marker. It implements both ISender<ICommand> and IReceiver<ICommand>. Inject it directly or through one of those interfaces to send and receive commands via Azure Storage queues.

using Savvyio.Commands;
using Savvyio.Extensions.QueueStorage.Commands;
using Savvyio.Messaging;

namespace ExampleApp;

public sealed class AzureCommandService
{
    private readonly ISender<ICommand> _sender;
    private readonly IReceiver<ICommand> _receiver;

    public AzureCommandService(AzureCommandQueue queue)
    {
        _sender = queue;
        _receiver = queue;
    }

    public ISender<ICommand> Sender => _sender;
    public IReceiver<ICommand> Receiver => _receiver;
}

Constructors

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

See Also

AzureCommandQueue

IPointToPointChannel<TRequest, TMarker>