Struct AmqpContext 

pub struct AmqpContext { /* private fields */ }

Native AMQP delivery metadata, built once per delivery.

Implementations

impl AmqpContext

pub fn exchange(&self) -> &str

The exchange the 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 the delivery as redelivered.

pub fn delivery_tag(&self) -> u64

The channel-local delivery tag.

Trait Implementations

impl BuildContext<LapinMessage> for AmqpContext

fn build(msg: &LapinMessage) -> Self

Builds the context value by reading fields out of msg.

impl Clone for AmqpContext

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AmqpContext

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

Formats the value using the given formatter.

impl Default for AmqpContext

fn default() -> Self

Returns the “default value” for a type.

impl Eq for AmqpContext

impl Field<AmqpContext> for Exchange

type Value<'a> = &'a str

The value read through this key, borrowed from the source for 'a.

fn get(self, src: &AmqpContext) -> &str

Reads this key’s field out of src.

impl Field<AmqpContext> for RoutingKey

type Value<'a> = &'a str

The value read through this key, borrowed from the source for 'a.

fn get(self, src: &AmqpContext) -> &str

Reads this key’s field out of src.

impl Field<AmqpContext> for Redelivered

type Value<'a> = bool

The value read through this key, borrowed from the source for 'a.

fn get(self, src: &AmqpContext) -> bool

Reads this key’s field out of src.

impl Field<AmqpContext> for DeliveryTag

type Value<'a> = u64

The value read through this key, borrowed from the source for 'a.

fn get(self, src: &AmqpContext) -> u64

Reads this key’s field out of src.

impl PartialEq for AmqpContext

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for AmqpContext