Struct InMessage

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

Fields

message_format: Option<MessageFormat>

Implementations

impl InMessage

pub fn with_body(body: Bytes) -> InMessage

Create new message and set body

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

Create new message and set messages as body

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

Header

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

Set message header

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

Message properties

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

where F: Fn(&mut Properties),

Add property

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

Get application property

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

Get application properties

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

Get message annotation

pub fn set_app_property<K: Into<Str>, V: Into<Variant>>( self, key: K, value: V, ) -> Self

Add application property

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>>(self, v: V) -> Self

Set message body value

pub fn set_body<F>(self, f: F) -> 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 InMessage

fn clone(&self) -> InMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMessage

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

Formats the value using the given formatter.

impl Decode for InMessage

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

impl Default for InMessage

fn default() -> InMessage

Returns the “default value” for a type.

impl Encode for InMessage

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<InMessage> for TransferBody

fn from(original: InMessage) -> TransferBody

Converts to this type from the input type.

impl PartialEq for InMessage

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