Struct AmqpMessage 

pub struct AmqpMessage { /* private fields */ }

A message delivered by an AmqpSubscriber.

ack maps to the accept disposition, nack(requeue = true) to modified with delivery-failed set (so the broker counts the attempt and redelivers), and nack(requeue = false) to reject (terminal; the broker’s dead-letter policy applies). Deliveries received on an at-most-once subscription are already settled, so ack/nack report AckError::Unsupported instead of pretending.

Trait Implementations

impl Debug for AmqpMessage

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

Formats the value using the given formatter.

impl IncomingMessage for AmqpMessage

fn redelivery_count(&self) -> Option<u64>

The broker’s own count of deliveries of this message, from the delivery-count field of the AMQP header section, counting this delivery.

A delivery with no header section answers None, which is what a message this crate published looks like: nothing has counted an attempt for it, and the framework’s retry-count header carries the attempt instead. That is the answer a deferred retry_after copy needs, because the copy is a new message to the broker and its delivery-count starts over while the framework’s header does not.

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

Returns the raw payload of the message.

fn headers(&self) -> &HeaderMap

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.

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

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

fn decode_error(&self) -> Option<&CodecError>

The error the broker met while reading this delivery, or None when it read the delivery whole.

fn supports_nack_after(&self) -> bool

Reports whether this transport can honor nack_after natively.

fn nack_after( self, delay: Duration, ) -> impl Future<Output = Result<(), AckError>> + Send

where Self: Sized,

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

impl Partitioned for AmqpMessage

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

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