Struct SqsQueue 

pub struct SqsQueue { /* private fields */ }

A subscription descriptor for one SQS queue.

Accepts a queue URL or a queue name (resolved through GetQueueUrl on subscribe). Implements SubscriptionSource, so it can sit inline in the #[subscriber(..)] decorator:

use std::time::Duration;
use ruststream_sqs_sns::SqsQueue;

let source = SqsQueue::new("orders")
    .wait(Duration::from_secs(20))
    .batch(10)
    .visibility(Duration::from_secs(30));

Implementations

impl SqsQueue

pub fn new(queue: impl Into<String>) -> Self

Names the queue by URL (https://sqs...) or by name.

pub fn wait(self, wait: Duration) -> Self

Long-polling wait per receive call. Defaults to the protocol maximum of 20 seconds; values above it are rejected before any I/O.

pub fn batch(self, batch: i32) -> Self

Messages per receive call (1..=10, the protocol cap). Defaults to 10.

pub fn visibility(self, visibility: Duration) -> Self

The visibility timeout requested per receive; the crate extends it in the background while a handler holds the message. Defaults to the queue’s configured timeout.

pub fn create_if_missing(self) -> Self

Creates the queue on subscribe when it does not exist yet (a name ending in .fifo creates a FIFO queue with content-based deduplication). Meant for local development and tests; production queues are usually managed as infrastructure.

pub fn queue(&self) -> &str

The queue URL or name this descriptor resolves.

Trait Implementations

impl Clone for SqsQueue

fn clone(&self) -> SqsQueue

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SqsQueue

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Eq for SqsQueue

impl PartialEq for SqsQueue

fn eq(&self, other: &SqsQueue) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for SqsQueue

impl SubscriptionSource<ConnectedSqsBroker> for SqsQueue

type Subscriber = SqsSubscriber

The subscriber type this source opens.

fn name(&self) -> &str

The name (subject / channel) this subscription binds to.

async fn subscribe( self, connected: &ConnectedSqsBroker, ) -> Result<SqsSubscriber, SqsError>

Opens the subscription against the connected broker. Called once at startup.