SQS

Message queues for asynchronous processing.

Fully Supported

Supported Operations

Operation	Status	Notes
CreateQueue	Supported	Standard and FIFO
DeleteQueue	Supported
ListQueues	Supported
GetQueueAttributes	Supported
SetQueueAttributes	Supported	Visibility timeout, message retention
SendMessage	Supported	With attributes and deduplication
SendMessageBatch	Supported	Up to 10 messages
ReceiveMessage	Supported	Long polling, message attributes
DeleteMessage	Supported
DeleteMessageBatch	Supported
PurgeQueue	Supported	Clear all messages
CreateEventSourceMapping	Supported	Trigger Lambda on messages

Features

FIFO Queues

Process messages in order with deduplication:

await sqs.send(new SendMessageCommand({
  QueueUrl: "https://queue.fifo",
  MessageBody: "data",
  MessageGroupId: "group1",
  MessageDeduplicationId: "unique-id"
}));

Event Source Mappings

Automatically invoke Lambda when messages arrive:

awslocal lambda create-event-source-mapping \
  --event-source-arn arn:aws:sqs:us-east-1:000000000000:my-queue \
  --function-name processor \
  --batch-size 10

Dead Letter Queues

Capture messages that fail processing:

HCL (Terraform)

resource "aws_sqs_queue" "main" {
  name = "main-queue"
  message_retention_seconds = 86400
}

resource "aws_sqs_queue" "dlq" {
  name = "main-queue-dlq"
}

resource "aws_sqs_queue_redrive_policy" "main" {
  queue_url = aws_sqs_queue.main.id
  redrive_policy = jsonencode({
    deadLetterTargetArn = aws_sqs_queue.dlq.arn
    maxReceiveCount     = 3
  })
}

Examples

Send and Receive

JavaScript

import { SQSClient, SendMessageCommand, ReceiveMessageCommand, DeleteMessageCommand } from "@aws-sdk/client-sqs";

const sqs = new SQSClient({ endpoint: "http://127.0.0.1:4566" });

// Send
const sendRes = await sqs.send(new SendMessageCommand({
  QueueUrl: "https://sqs.us-east-1.amazonaws.com/000000000000/my-queue",
  MessageBody: JSON.stringify({ task: "process-order", orderId: "123" }),
  MessageAttributes: {
    Priority: { DataType: "Number", StringValue: "5" }
  }
}));

// Receive
const receiveRes = await sqs.send(new ReceiveMessageCommand({
  QueueUrl: "https://sqs.us-east-1.amazonaws.com/000000000000/my-queue",
  MaxNumberOfMessages: 10,
  WaitTimeSeconds: 20, // Long polling
  MessageAttributeNames: ["All"]
}));

for (const msg of receiveRes.Messages || []) {
  console.log("Message:", msg.Body);

  // Process and delete
  await sqs.send(new DeleteMessageCommand({
    QueueUrl: "...",
    ReceiptHandle: msg.ReceiptHandle
  }));
}

Known Limitations

• No KMS encryption
• SQS-managed server-side encryption is a compatibility stub, not real encryption