Struct SqsService

pub struct SqsService {
    client: Client,
}

SQS service for interacting with AWS SQS

This service provides a high-level interface for SQS operations with dependency injection for better performance and testability.

Fields

client: Client

Implementations

impl SqsService

pub fn with_client(client: Client) -> Self

Create a new SQS service with a custom client

Arguments

• client - The SQS client to use

Returns

Returns a new SqsService instance with the provided client.

pub fn with_config(config: &SdkConfig) -> Self

Create a new SQS service with a shared configuration

Arguments

• config - The AWS SDK configuration to use

Returns

Returns a new SqsService instance with the provided configuration.

pub async fn get_queue(&self, name: &str) -> Result<String>

Get an SQS queue URL

Arguments

• name - The name of the queue to get

Returns

Returns the queue URL as a String

Errors

• SqsError::Service - If the SQS client fails to create.
• SqsError::Timeout - If the request times out.
• SqsError::Transport - If the request fails to dispatch.
• SqsError::Build - If the request fails to build.
• SqsError::InvalidResponse - If the queue URL is not found.

pub async fn send_message( &self, queue_url: &str, body: &str, delay_seconds: Option<i32>, ) -> Result<String>

Send an SQS message

Arguments

• queue_url - The URL of the queue to send
• body - The message to send
• delay_seconds - The delay in seconds before the message is sent

Returns

Returns the message ID as a String

Errors

• SqsError::Service - If the SQS client fails to create.
• SqsError::Timeout - If the request times out.
• SqsError::Transport - If the request fails to dispatch.
• SqsError::Build - If the request fails to build.
• SqsError::InvalidResponse - If the message ID is not found.