Struct QueueBuilder 

pub struct QueueBuilder<T: QueueBuilderState> { /* private fields */ }

Builder for SQS queues.

Supports both standard and FIFO queues. FIFO queues have additional configuration options for deduplication and throughput.

Example

use rusty_cdk_core::stack::StackBuilder;
use rusty_cdk_core::sqs::QueueBuilder;
use rusty_cdk_core::wrappers::*;
use rusty_cdk_macros::{delay_seconds, message_retention_period, visibility_timeout};

let mut stack_builder = StackBuilder::new();

// Create a standard queue
let standard_queue = QueueBuilder::new("standard-queue")
    .standard_queue()
    .visibility_timeout(visibility_timeout!(60))
    .build(&mut stack_builder);
 
// Create a FIFO queue
let queue = QueueBuilder::new("my-queue")
    .fifo_queue()
    .content_based_deduplication(true)
    .delay_seconds(delay_seconds!(30))
    .message_retention_period(message_retention_period!(600))
    .build(&mut stack_builder);

Implementations

impl QueueBuilder<StartState>

pub fn new(id: &str) -> Self

Creates a new SQS queue builder.

Arguments

• id - Unique identifier for the queue

pub fn standard_queue(self) -> QueueBuilder<StandardState>

pub fn fifo_queue(self) -> QueueBuilder<FifoState>

impl<T: QueueBuilderState> QueueBuilder<T>

pub fn delay_seconds(self, delay: DelaySeconds) -> Self

pub fn maximum_message_size(self, size: MaximumMessageSize) -> Self

pub fn message_retention_period(self, period: MessageRetentionPeriod) -> Self

pub fn receive_message_wait_time_seconds( self, wait_time: ReceiveMessageWaitTime, ) -> Self

pub fn visibility_timeout(self, timeout: VisibilityTimeout) -> Self

pub fn sqs_managed_sse_enabled(self, enabled: bool) -> Self

pub fn dead_letter_queue<D: Into<String>>( self, dead_letter_target_arn: D, max_receive_count: NonZeroNumber, ) -> Self

pub fn redrive_allow_policy(self, policy: Value) -> Self

pub fn queue_name(self, name: StringWithOnlyAlphaNumericsAndUnderscores) -> Self

impl QueueBuilder<StandardState>

pub fn build(self, stack_builder: &mut StackBuilder) -> QueueRef

impl QueueBuilder<FifoState>

pub fn content_based_deduplication(self, enabled: bool) -> Self

pub fn high_throughput_fifo(self) -> Self

Enables high throughput mode for FIFO queues.

Sets deduplication scope to MessageGroup and throughput limit to PerMessageGroupId.

pub fn deduplication_scope(self, scope: DeduplicationScope) -> Self

pub fn fifo_throughput_limit(self, limit: FifoThroughputLimit) -> Self

pub fn build(self, stack_builder: &mut StackBuilder) -> QueueRef

Builds the FIFO queue and adds it to the stack.

Automatically appends the required “.fifo” suffix to the queue name if not already present.