Struct SqsMessage 

pub struct SqsMessage { /* private fields */ }

A message delivered by an SqsSubscriber.

ack deletes the message; nack(requeue = true) zeroes its visibility so it redelivers immediately; nack_after(delay) sets the visibility to the delay, so deferred retry is native. nack(requeue = false) deletes: SQS has no drop verb short of deletion - poison routing belongs to the queue’s redrive policy, driven by repeated requeues.

While the handle is alive, a background task keeps extending the message’s visibility, so a handler outliving the visibility timeout does not cause a concurrent redelivery.

Trait Implementations

impl Debug for SqsMessage

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

Formats the value using the given formatter.

impl Drop for SqsMessage

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl IncomingMessage for SqsMessage

fn supports_nack_after(&self) -> bool

Every SQS delivery honors a delayed redelivery: the visibility timeout is the delay, so the runtime must take nack_after here instead of its broker-agnostic deferred re-publish, which would re-publish a copy and reset the receive count.

fn payload(&self) -> &[u8]

Returns the raw payload of the message.

fn headers(&self) -> &Headers

Returns the headers attached to the message.

async fn ack(self) -> Result<(), AckError>

Acknowledges successful processing. Consumes the message handle.

async fn nack(self, requeue: bool) -> Result<(), AckError>

Negatively acknowledges the message. When requeue is true the broker should redeliver according to its own retry policy; when false it should drop or dead-letter the message.

async fn nack_after(self, delay: Duration) -> Result<(), AckError>

Negatively acknowledges the message, asking the broker to redeliver it no sooner than delay from now.

fn partition_key(&self) -> Option<&[u8]>

Returns the routing key the broker partitioned this message by, or None when the message carries no key.

impl Partitioned for SqsMessage

fn partition_key(&self) -> Option<&[u8]>

Returns the partition key for this item, or None if the broker should pick a partition.