Struct LapinMessage 

pub struct LapinMessage { /* private fields */ }

One AMQP delivery, settled with the protocol’s native acknowledgement frames.

Settlement mapping:

• ack sends basic.ack.
• nack(true) sends basic.nack with requeue = true; the broker redelivers the message (typically to the same queue, redelivered set).
• nack(false) sends basic.reject with requeue = false; the broker drops the message, or dead-letters it when the queue has a dead-letter exchange.

Replies received through LapinRequester arrive on a no-ack consumer; settling them is a no-op that always succeeds.

Implementations

impl LapinMessage

pub fn exchange(&self) -> &str

The exchange this message was published to (empty for the default exchange).

pub fn routing_key(&self) -> &str

The routing key the message was published with.

pub fn redelivered(&self) -> bool

Whether the broker marked this delivery as redelivered.

pub fn delivery_tag(&self) -> u64

The channel-local delivery tag of this delivery.

Trait Implementations

impl BuildContext<LapinMessage> for AmqpContext

fn build(msg: &LapinMessage) -> Self

Builds the context value by reading fields out of msg.

impl Debug for LapinMessage

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

Formats the value using the given formatter.

impl IncomingMessage for LapinMessage

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

Acknowledges the delivery with basic.ack.

Errors

Returns AckError::Broker when the frame cannot be sent, for example because the channel closed after the delivery arrived.

Cancel safety

Not cancel safe: dropping the future after the frame was queued may still acknowledge the message on the broker.

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

Settles negatively: basic.nack(requeue = true) or basic.reject(requeue = false).

Errors

Returns AckError::Broker when the frame cannot be sent, for example because the channel closed after the delivery arrived.

Cancel safety

Not cancel safe: dropping the future after the frame was queued may still settle the message on the broker.

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

Returns the raw payload of the message.

fn headers(&self) -> &Headers

Returns the headers attached to 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 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.