Struct amqp_codec::OutMessage

pub struct OutMessage {
    pub message_format: Option<MessageFormat>,
    // some fields omitted
}

Fields

message_format: Option<MessageFormat>

Methods

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 Encode for OutMessage

fn encoded_size(&self) -> usize

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

impl Decode for OutMessage

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

impl From<InMessage> for OutMessage

fn from(from: InMessage) -> Self

Performs the conversion.

impl From<OutMessage> for TransferBody

fn from(original: OutMessage) -> TransferBody

Performs the conversion.

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 Default for OutMessage

fn default() -> OutMessage

Returns the "default value" for a type.

impl PartialEq<OutMessage> for OutMessage

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

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

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

This method tests for !=.

impl Debug for OutMessage

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

Formats the value using the given formatter.

impl StructuralPartialEq for OutMessage