Messaging

SQS

Protocol: Query (XML) and JSON 1.0 (both supported)
Endpoint: POST http://localhost:4566/ SQS supports Standard and FIFO queues, dead-letter queues, visibility timeout, and batch operations. Queue URL format:

http://localhost:4566/000000000000/<queue-name>

SQS operations (20)

Action	Description
`CreateQueue`	Create a standard or FIFO queue
`DeleteQueue`	Delete a queue
`ListQueues`	List all queues
`GetQueueUrl`	Look up a queue URL by name
`GetQueueAttributes`	Get queue configuration attributes
`SetQueueAttributes`	Update queue configuration
`SendMessage`	Send a message to a queue
`SendMessageBatch`	Send up to 10 messages in one call
`ReceiveMessage`	Poll for messages
`DeleteMessage`	Acknowledge and delete a message
`DeleteMessageBatch`	Delete multiple messages at once
`ChangeMessageVisibility`	Extend or reset a message’s visibility timeout
`ChangeMessageVisibilityBatch`	Change visibility for multiple messages
`PurgeQueue`	Delete all messages in a queue
`TagQueue`	Add tags to a queue
`UntagQueue`	Remove tags from a queue
`ListQueueTags`	List tags on a queue
`ListDeadLetterSourceQueues`	Find queues that use this queue as DLQ
`StartMessageMoveTask`	Start a DLQ redrive task
`ListMessageMoveTasks`	List DLQ redrive tasks

Configuration

floci:
  services:
    sqs:
      enabled: true
      default-visibility-timeout: 30  # Seconds
      max-message-size: 262144        # 256 KB

Examples

export AWS_ENDPOINT=http://localhost:4566

# Create a standard queue
aws sqs create-queue --queue-name orders --endpoint-url $AWS_ENDPOINT

# Create a FIFO queue
aws sqs create-queue \
  --queue-name orders.fifo \
  --attributes FifoQueue=true \
  --endpoint-url $AWS_ENDPOINT

# Send a message
QUEUE_URL="$AWS_ENDPOINT/000000000000/orders"
aws sqs send-message \
  --queue-url $QUEUE_URL \
  --message-body '{"event":"order.placed","id":"abc123"}' \
  --endpoint-url $AWS_ENDPOINT

# Receive messages
aws sqs receive-message \
  --queue-url $QUEUE_URL \
  --max-number-of-messages 10 \
  --endpoint-url $AWS_ENDPOINT

# Delete a message (replace RECEIPT_HANDLE with the value from ReceiveMessage)
aws sqs delete-message \
  --queue-url $QUEUE_URL \
  --receipt-handle "RECEIPT_HANDLE" \
  --endpoint-url $AWS_ENDPOINT

# Set up a dead-letter queue
DLQ_ARN=$(aws sqs get-queue-attributes \
  --queue-url $AWS_ENDPOINT/000000000000/orders-dlq \
  --attribute-names QueueArn \
  --query Attributes.QueueArn \
  --output text \
  --endpoint-url $AWS_ENDPOINT)

aws sqs set-queue-attributes \
  --queue-url $QUEUE_URL \
  --attributes "{\"RedrivePolicy\":\"{\\\"deadLetterTargetArn\\\":\\\"$DLQ_ARN\\\",\\\"maxReceiveCount\\\":3}\"}" \
  --endpoint-url $AWS_ENDPOINT

SNS

Protocol: Query (XML) and JSON 1.0 (both supported)
Endpoint: POST http://localhost:4566/ SNS supports topics, subscriptions, and real fan-out to SQS queues, Lambda functions, and HTTP endpoints.

SNS operations (17)

Action	Description
`CreateTopic`	Create a topic
`DeleteTopic`	Delete a topic
`ListTopics`	List all topics
`GetTopicAttributes`	Get topic configuration
`SetTopicAttributes`	Update topic configuration
`Subscribe`	Subscribe an endpoint (SQS, HTTP, Lambda, email)
`Unsubscribe`	Remove a subscription
`ListSubscriptions`	List all subscriptions
`ListSubscriptionsByTopic`	List subscriptions for a specific topic
`GetSubscriptionAttributes`	Get subscription settings
`SetSubscriptionAttributes`	Update subscription settings
`ConfirmSubscription`	Confirm a pending subscription
`Publish`	Publish a message to a topic
`PublishBatch`	Publish up to 10 messages in one call
`TagResource`	Tag a topic
`UntagResource`	Remove tags from a topic
`ListTagsForResource`	List tags on a topic

Supported subscription protocols: sqs, lambda, http, https.

Examples

export AWS_ENDPOINT=http://localhost:4566

# Create a topic
TOPIC_ARN=$(aws sns create-topic --name notifications \
  --query TopicArn --output text \
  --endpoint-url $AWS_ENDPOINT)

# Subscribe an SQS queue
QUEUE_ARN=$(aws sqs get-queue-attributes \
  --queue-url $AWS_ENDPOINT/000000000000/orders \
  --attribute-names QueueArn \
  --query Attributes.QueueArn --output text \
  --endpoint-url $AWS_ENDPOINT)

aws sns subscribe \
  --topic-arn $TOPIC_ARN \
  --protocol sqs \
  --notification-endpoint $QUEUE_ARN \
  --endpoint-url $AWS_ENDPOINT

# Publish a message
aws sns publish \
  --topic-arn $TOPIC_ARN \
  --message '{"event":"user.registered"}' \
  --endpoint-url $AWS_ENDPOINT

# Fan-out: verify the SQS queue received the message
aws sqs receive-message \
  --queue-url $AWS_ENDPOINT/000000000000/orders \
  --endpoint-url $AWS_ENDPOINT

EventBridge

Protocol: JSON 1.1 (X-Amz-Target: AmazonEventBridge.*)
Endpoint: POST http://localhost:4566/ EventBridge supports custom event buses, rules with event patterns, and targets including SQS, SNS, and Lambda. A default event bus is always available.

EventBridge operations (14)

Action	Description
`CreateEventBus`	Create a custom event bus
`DeleteEventBus`	Delete an event bus
`DescribeEventBus`	Get event bus details
`ListEventBuses`	List all event buses
`PutRule`	Create or update a rule with a schedule or event pattern
`DeleteRule`	Delete a rule
`DescribeRule`	Get rule details
`ListRules`	List rules
`EnableRule`	Enable a disabled rule
`DisableRule`	Disable a rule
`PutTargets`	Add targets to a rule
`RemoveTargets`	Remove targets from a rule
`ListTargetsByRule`	List targets for a rule
`PutEvents`	Publish custom events to an event bus

Examples

export AWS_ENDPOINT=http://localhost:4566

# Create a custom event bus
aws events create-event-bus \
  --name my-bus \
  --endpoint-url $AWS_ENDPOINT

# Create a rule matching a pattern
aws events put-rule \
  --name order-placed-rule \
  --event-bus-name my-bus \
  --event-pattern '{"source":["com.myapp"],"detail-type":["OrderPlaced"]}' \
  --state ENABLED \
  --endpoint-url $AWS_ENDPOINT

# Add a Lambda target
aws events put-targets \
  --rule order-placed-rule \
  --event-bus-name my-bus \
  --targets '[{
    "Id": "process-order",
    "Arn": "arn:aws:lambda:us-east-1:000000000000:function:process-order"
  }]' \
  --endpoint-url $AWS_ENDPOINT

# Publish an event
aws events put-events \
  --entries '[{
    "Source": "com.myapp",
    "DetailType": "OrderPlaced",
    "Detail": "{\"orderId\":\"123\",\"amount\":99.99}",
    "EventBusName": "my-bus"
  }]' \
  --endpoint-url $AWS_ENDPOINT

# Send to the default bus
aws events put-events \
  --entries '[{"Source":"myapp","DetailType":"test","Detail":"{}"}]' \
  --endpoint-url $AWS_ENDPOINT

Kinesis

Protocol: JSON 1.1 (X-Amz-Target: Kinesis_20131202.*)
Endpoint: POST http://localhost:4566/ Kinesis supports streams with multiple shards, enhanced fan-out consumers, shard split and merge operations, and KMS encryption.

Kinesis operations (21)

Action	Description
`CreateStream`	Create a stream
`DeleteStream`	Delete a stream
`ListStreams`	List all streams
`DescribeStream`	Get stream details and shard info
`DescribeStreamSummary`	Lightweight stream description
`RegisterStreamConsumer`	Register an enhanced fan-out consumer
`DeregisterStreamConsumer`	Remove a consumer
`DescribeStreamConsumer`	Get consumer details
`ListStreamConsumers`	List consumers for a stream
`SubscribeToShard`	Subscribe to a shard for enhanced fan-out
`PutRecord`	Write a single record
`PutRecords`	Write up to 500 records
`GetShardIterator`	Get an iterator for reading
`GetRecords`	Read records from a shard
`SplitShard`	Split a shard into two
`MergeShards`	Merge two adjacent shards
`AddTagsToStream`	Tag a stream
`RemoveTagsFromStream`	Remove tags
`ListTagsForStream`	List tags
`StartStreamEncryption`	Enable KMS encryption
`StopStreamEncryption`	Disable encryption

Examples

export AWS_ENDPOINT=http://localhost:4566

# Create a stream
aws kinesis create-stream \
  --stream-name events \
  --shard-count 2 \
  --endpoint-url $AWS_ENDPOINT

# Put a record
aws kinesis put-record \
  --stream-name events \
  --partition-key "user-123" \
  --data '{"event":"page_view","page":"/home"}' \
  --endpoint-url $AWS_ENDPOINT

# Get a shard iterator
SHARD_ID=$(aws kinesis describe-stream \
  --stream-name events \
  --query 'StreamDescription.Shards[0].ShardId' --output text \
  --endpoint-url $AWS_ENDPOINT)

ITERATOR=$(aws kinesis get-shard-iterator \
  --stream-name events \
  --shard-id $SHARD_ID \
  --shard-iterator-type TRIM_HORIZON \
  --query ShardIterator --output text \
  --endpoint-url $AWS_ENDPOINT)

# Read records
aws kinesis get-records \
  --shard-iterator $ITERATOR \
  --endpoint-url $AWS_ENDPOINT

Get Started

Configuration

Services

Contributing

SQS

Configuration

Examples

SNS

Examples

EventBridge

Examples

Kinesis

Examples

Build docs developers (and LLMs) love

Get Started

Configuration

Services

Contributing

​SQS

​Configuration

​Examples

​SNS

​Examples

​EventBridge

​Examples

​Kinesis

​Examples

Build docs developers (and LLMs) love

SQS

Configuration

Examples

SNS

Examples

EventBridge

Examples

Kinesis

Examples