Struct Message 

pub struct Message(pub Box<MessageInner>);

Tuple Fields

0: Box<MessageInner>

Implementations

impl Message

pub fn with_body(body: Bytes) -> Message

Create new message and set body

pub fn with_messages(messages: Vec<TransferBody>) -> Message

Create new message and set messages as body

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

Header

pub fn set_header(&mut self, header: Header) -> &mut Self

Set message header

pub fn set_format(&mut self, format: MessageFormat) -> &mut Self

Set message format

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

Message properties

pub fn properties_mut(&mut self) -> &mut Properties

Mutable reference to properties

pub fn set_properties<F>(&mut self, f: F) -> &mut Self

where F: FnOnce(&mut Properties),

Add property

pub fn app_properties(&self) -> Option<&VecStringMap>

Get application property

pub fn app_properties_mut(&mut self) -> Option<&mut VecStringMap>

Mut ref tp application property

pub fn app_property(&self, key: &str) -> Option<&Variant>

Get application property

pub fn set_app_property<K, V>(&mut self, key: K, value: V) -> &mut Self

where K: Into<Str>, V: Into<Variant>,

Add application property

pub fn message_annotation(&self, key: &str) -> Option<&Variant>

Get message annotation

pub fn add_message_annotation<K, V>(&mut self, key: K, value: V) -> &mut Self

where K: Into<Symbol>, V: Into<Variant>,

Add message annotation

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

Get message annotations

pub fn message_annotations_mut(&mut self) -> Option<&mut VecSymbolMap>

Mut reference to message annotations

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

Delivery annotations

pub fn delivery_annotations_mut(&mut self) -> Option<&mut VecSymbolMap>

Mut reference to delivery annotations

pub fn update<F>(self, f: F) -> Self

where F: Fn(Self) -> Self,

Call closure with message reference

pub fn if_some<T, F>(self, value: &Option<T>, f: F) -> Self

where F: Fn(Self, &T) -> Self,

Call closure if value is Some value

pub fn body(&self) -> &MessageBody

Message body

pub fn body_mut(&mut self) -> &mut MessageBody

Mutable message body

pub fn value(&self) -> Option<&Variant>

Message value

pub fn set_value<V: Into<Variant>>(&mut self, v: V) -> &mut Self

Set message body value

pub fn set_body<F>(&mut self, f: F) -> &mut Self

where F: FnOnce(&mut MessageBody),

Set message body

pub fn reply_message(&self) -> Message

Create new message and set correlation_id property

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 Decode for Message

fn decode(input: &mut Bytes) -> Result<Message, AmqpParseError>

Decodes the type from the provided buffer.

impl Default for Message

fn default() -> Message

Returns the “default value” for a type.

impl Encode for Message

fn encoded_size(&self) -> usize

Returns the size of the type when encoded.

fn encode(&self, dst: &mut BytesMut)

Encodes the type into the provided buffer.

impl From<Message> for TransferBody

fn from(value: 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 Eq for Message

impl StructuralPartialEq for Message