Struct lapin::message::Delivery

pub struct Delivery {
    pub delivery_tag: DeliveryTag,
    pub exchange: ShortString,
    pub routing_key: ShortString,
    pub redelivered: bool,
    pub properties: BasicProperties,
    pub data: Vec<u8>,
    pub acker: Acker,
}

A received AMQP message.

The message has to be acknowledged after processing by calling Acker::ack, Acker::nack or Acker::reject. (Multiple acknowledgments are also possible).

Fields

delivery_tag: DeliveryTag

The delivery tag of the message. Use this for acknowledging the message.

exchange: ShortString

The exchange of the message. May be an empty string if the default exchange is used.

routing_key: ShortString

The routing key of the message. May be an empty string if no routing key is specified.

redelivered: bool

Whether this message was redelivered

properties: BasicProperties

Contains the properties and the headers of the message.

data: Vec<u8>

The payload of the message in binary format.

acker: Acker

The acker used to ack/nack the message

Methods from Deref<Target = Acker>

pub async fn ack(&self, options: BasicAckOptions) -> Result<()>

pub async fn nack(&self, options: BasicNackOptions) -> Result<()>

pub async fn reject(&self, options: BasicRejectOptions) -> Result<()>

pub fn used(&self) -> bool

Trait Implementations

impl Debug for Delivery

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

Formats the value using the given formatter.

impl Deref for Delivery

type Target = Acker

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl PartialEq for Delivery

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

This method tests for self and other values to be equal, and is used by ==.

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

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for Delivery