AmazonCommandQueue<TMarker> Class

Definition

Namespace

Savvyio.Extensions.DependencyInjection.SimpleQueueService.Commands

Assemblies

Savvyio.Extensions.DependencyInjection.SimpleQueueService.dll

Source

src/Savvyio.Extensions.DependencyInjection.SimpleQueueService/Commands/AmazonCommandQueue.cs

Provides a default implementation of the AmazonQueue<TRequest> class tailored for messages holding an ICommand implementation.

public class AmazonCommandQueue<TMarker> : AmazonCommandQueue, IConfigurable<AmazonMessageOptions>, IHealthCheckProvider<IAmazonSQS>, IPointToPointChannel<ICommand, TMarker>, IPointToPointChannel<ICommand>, ISender<ICommand, TMarker>, ISender<ICommand>, IReceiver<ICommand, TMarker>, IReceiver<ICommand>, IDependencyInjectionMarker<TMarker>

Type Parameters

TMarker

Inheritance

object

AmazonMessage<ICommand>

AmazonQueue<ICommand>

AmazonCommandQueue

AmazonCommandQueue<TMarker>

Implements

IConfigurable<AmazonMessageOptions>

IHealthCheckProvider<IAmazonSQS>

IPointToPointChannel<ICommand, TMarker>

IPointToPointChannel<ICommand>

ISender<ICommand, TMarker>

ISender<ICommand>

IReceiver<ICommand, TMarker>

IReceiver<ICommand>

IDependencyInjectionMarker<TMarker>

Inherited Members

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

AmazonCommandQueue.ReceiveAsync(Action<AsyncOptions>)

AmazonCommandQueue.GetHealthCheckTarget()

AmazonMessage<ICommand>.MessageTypeAttributeKey

AmazonMessage<ICommand>.UseFirstInFirstOut

AmazonMessage<ICommand>.Marshaller

AmazonMessage<ICommand>.Options

AmazonMessage<ICommand>.RetrieveMessagesAsync(CancellationToken)

AmazonMessage<ICommand>.CreateSimpleQueueServiceClient()

Examples

AmazonCommandQueue<TMarker> is the DI-registered Amazon SQS command queue with a lifetime marker. Inject it and use it as IPointToPointChannel<ICommand> to send and receive commands through Amazon SQS, or as ISender<ICommand> when only the send path is needed.

using Savvyio.Commands;
using Savvyio.Extensions.SimpleQueueService.Commands;
using Savvyio.Messaging;

namespace ExampleApp;

public sealed class SqsCommandService
{
    private readonly IPointToPointChannel<ICommand> _channel;

    public SqsCommandService(AmazonCommandQueue queue)
    {
        _channel = queue;
    }

    public IPointToPointChannel<ICommand> Channel => _channel;
}

Constructors

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

See Also

AmazonCommandQueue

IPointToPointChannel<TRequest, TMarker>