Struct Message 

pub struct Message(/* private fields */);

API for inbound and outbound messages

Implementations

impl Message

pub fn builder() -> MessageBuilder

Builder for creating Message

pub fn value_ref<'a, T>(&'a self) -> Result<Option<T>, DecodeError>

where T: TryFrom<&'a Value, Error = DecodeError>,

Extract a value as reference from the amqp-value section of the body if present

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

Get the data associated to the message if any

pub fn properties(&self) -> Option<&Properties>

Get the properties of the message

pub fn header(&self) -> Option<&Header>

Get the header of the message

pub fn message_annotations(&self) -> Option<&MessageAnnotations>

Get the annotations of the message

pub fn application_properties(&self) -> Option<&ApplicationProperties>

Get the application properties of the message

pub fn delivery_annotations(&self) -> Option<&DeliveryAnnotations>

Get the delivery annotations of the message

pub fn publishing_id(&self) -> Option<&u64>

Get a reference to the message’s publishing id.

Trait Implementations

impl Clone for Message

fn clone(&self) -> Message

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Message

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

Formats the value using the given formatter.

impl Decoder for Message

fn decode(input: &[u8]) -> Result<(&[u8], Self), DecodeError>

fn decode_version_2(input: &[u8]) -> Result<(&[u8], Self), DecodeError>

impl Encoder for Message

fn encoded_size(&self) -> u32

fn encode(&self, writer: &mut impl Write) -> Result<(), EncodeError>

fn encoded_size_version_2(&self) -> u32

fn encode_version_2(&self, writer: &mut impl Write) -> Result<(), EncodeError>

impl Eq for Message

impl From<Message> for Vec<Message>

fn from(message: Message) -> Self

Converts to this type from the input type.

impl PartialEq for Message

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

Tests for self and other values to be equal, and is used by ==.

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

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

impl StructuralPartialEq for Message