Struct icee_rabbit_rs::Message

pub struct Message {
    pub data: Vec<u8>,
    pub headers: FieldTable,
}

Message constructed from AmqpMessage

Fields

data: Vec<u8>

headers: FieldTable

Implementations

impl Message

pub fn add_header(&mut self, key: &str, value: String)

Sets a header for AmqpMessage

pub fn header_string(&self, key: &str) -> Option<String>

Receives header in Option format

Parse String and Int values. If the header is missing or is in different format, returns None

let message = Message { data: vec![], headers: FieldTable::default(), };
let value = message.header_string("key");

pub fn header_string_default<F: FnOnce() -> String>(
    &self,
    key: &str,
    or_else: F
) -> String

Receives header in String format

Parse String and Int values. If the header or is in different format returns given default

let message = Message { data: vec![], headers: FieldTable::default(), };
let value = message.header_string_default("key", || "default".into());

pub fn header_i32(&self, key: &str) -> Option<i32>

Receives header in Option format

Parse Int and tries to parse String values. If the header is missing or is not valid number, returns None

let message = Message { data: vec![], headers: FieldTable::default(), };
let value = message.header_i32("key");

pub fn header_i32_default(&self, key: &str, default: i32) -> i32

Receives header in i32 format

Parse Int and tries to parse String values. If the header is missing or is not valid number, returns given default

let message = Message { data: vec![], headers: FieldTable::default(), };
let value = message.header_i32_default("key", 1);

Trait Implementations

impl Clone for Message

pub fn clone(&self) -> Message

Returns a copy of the value.

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

Performs copy-assignment from source.

impl From<&'_ Delivery> for Message

pub fn from(delivery: &Delivery) -> Self

Performs the conversion.