Struct OutMessage

pub struct OutMessage {
    pub message_format: Option<MessageFormat>,
    /* private fields */
}

Fields

message_format: Option<MessageFormat>

Implementations

impl OutMessage

pub fn with_body(body: Bytes) -> OutMessage

Create new message and set body

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

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 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: Fn(&mut Properties),

Add property

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

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 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 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 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: Fn(&mut MessageBody),

Set message body

pub fn reply_message(&self) -> OutMessage

Create new message and set correlation_id property

Trait Implementations

impl Clone for OutMessage

fn clone(&self) -> OutMessage

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for OutMessage

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

Formats the value using the given formatter.

impl Decode for OutMessage

fn decode(input: &[u8]) -> Result<(&[u8], OutMessage), AmqpParseError>

impl Default for OutMessage

fn default() -> OutMessage

Returns the “default value” for a type.

impl Encode for OutMessage

fn encoded_size(&self) -> usize

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

impl From<InMessage> for OutMessage

fn from(from: InMessage) -> Self

Converts to this type from the input type.

impl From<OutMessage> for TransferBody

fn from(original: OutMessage) -> TransferBody

Converts to this type from the input type.

impl PartialEq for OutMessage

fn eq(&self, other: &OutMessage) -> 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 OutMessage