Struct DeadLetterQueue 

pub struct DeadLetterQueue {
    pub config: SdkConfig,
    pub client: Client,
}

Client for interacting with AWS SQS dead letter queues.

Provides high-level operations for listing queues, polling messages, and clearing messages from queues.

Example

use dlq::DeadLetterQueue;

let config = aws_config::from_env().load().await;
let dlq = DeadLetterQueue::from_config(config);

// List all queues
let queues = dlq.list().await;

// Poll messages from a queue
dlq.poll("https://sqs.us-east-1.amazonaws.com/123456789/my-dlq").await;

Fields

config: SdkConfig

The AWS SDK configuration used for SQS operations

client: Client

The SQS client instance

Implementations

impl DeadLetterQueue

pub async fn send_batch( &self, queue_url: &str, messages: &[impl AsRef<str>], ) -> Result<(), SendError>

Sends multiple messages to SQS in a single batch request.

Uses the SQS SendMessageBatch API to efficiently send up to 10 messages at once. Each message is assigned a unique UUID as its batch entry ID.

Arguments

• queue_url - The URL of the SQS queue to send messages to
• messages - A slice of message bodies to send. Each item must implement AsRef<str>.

Returns

• Ok(()) - All messages were sent successfully
• Err(SendError) - An error occurred during the send operation

Errors

• SendError::BuildEntryFailed - A message entry couldn’t be constructed
• SendError::AwsSdkError - The SQS API returned an error

Example

use dlq::DeadLetterQueue;

let config = aws_config::from_env().load().await;
let dlq = DeadLetterQueue::from_config(config);

// Send multiple messages
dlq.send_batch("https://sqs.us-east-1.amazonaws.com/123/my-queue", &["message 1", "message 2", "message 3"]).await?;

// Empty batch is handled gracefully
let empty: Vec<String> = vec![];
dlq.send_batch("https://sqs.us-east-1.amazonaws.com/123/my-queue", &empty).await?;

impl DeadLetterQueue

pub fn from_config(config: SdkConfig) -> Self

Creates a DeadLetterQueue from a pre-built AWS SDK config.

This is the preferred constructor as it allows the caller to configure credentials and endpoints based on their needs (e.g., --local flag for LocalStack).

Arguments

• config - Pre-configured AWS SDK configuration

Example

use dlq::DeadLetterQueue;

let config = aws_config::from_env().load().await;
let dlq = DeadLetterQueue::from_config(config);

// List all queues
let queues = dlq.list().await;

pub async fn _clear( &self, url: String, message_id: String, receipt_handle: String, )

Deletes a message from the queue using batch delete.

This is primarily used internally to acknowledge processed messages.

Arguments

• url - The queue URL
• message_id - The SQS message ID
• receipt_handle - The receipt handle from when the message was received

pub async fn list(&self) -> Vec<String>

Lists all SQS queue URLs in the AWS account.

Handles pagination automatically, returning all queues regardless of count.

Returns

A vector of queue URL strings.

Example

use dlq::DeadLetterQueue;

let config = aws_config::from_env().load().await;
let dlq = DeadLetterQueue::from_config(config);

for queue_url in dlq.list().await {
    println!("Found queue: {}", queue_url);
}

pub async fn poll(&self, queue_url: &str)

Polls messages from a queue and prints them as JSON.

Continuously receives messages until the queue is empty or the maximum number of attempts (10) is reached. Each message is printed to stdout as a JSON object.

Arguments

• queue_url - The URL of the queue to poll messages from

Example

use dlq::DeadLetterQueue;

let config = aws_config::from_env().load().await;
let dlq = DeadLetterQueue::from_config(config);

// Poll a specific queue
dlq.poll("https://sqs.us-east-1.amazonaws.com/123/my-dlq").await;

Trait Implementations

impl Clone for DeadLetterQueue

fn clone(&self) -> DeadLetterQueue

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.