Table of Contents

SquidStd.Messaging.Sqs

AWS SQS/SNS transport for SquidStd.Messaging. Implements IQueueProvider over SQS (with a redrive policy to a dead-letter queue) and ITopicProvider via SNS+SQS fan-out, behind the same IMessageQueue / IMessageTopic API as the other providers. Registered with a single AddSqsMessaging(...) call. Connection details come from a shared AwsConfigEntry.

Install

dotnet add package SquidStd.Messaging.Sqs

Usage

using DryIoc;
using SquidStd.Aws.Abstractions.Data.Config;
using SquidStd.Messaging.Sqs.Data.Config;
using SquidStd.Messaging.Sqs.Extensions;

var container = new Container();
container.AddSqsMessaging(new SqsOptions { Aws = new AwsConfigEntry { Region = "eu-west-1" } });
// or: container.AddSqsMessaging("sqs://accessKey:secretKey@eu-west-1?endpoint=http://localhost:4566");
  • Queues are created on first use with a redrive policy to <queue><deadLetterSuffix> (max receive count = MessagingOptions.MaxDeliveryAttempts).
  • Topics map to SNS; each subscriber gets a dedicated SQS queue subscribed with raw message delivery.
  • Names are sanitized to the SQS/SNS alphabet (the default .dlq suffix becomes -dlq).
  • Payloads travel base64-encoded in the message body.

Key types

Type Purpose
SqsMessagingRegistrationExtensions AddSqsMessaging(...) registration.
SqsQueueProvider SQS-backed IQueueProvider.
SqsTopicProvider SNS+SQS-backed ITopicProvider.
SqsOptions AWS connection + queue/topic configuration.

License

MIT - part of SquidStd.

Edit this page