Struct QueueMessage 

pub struct QueueMessage {
    pub payload: Vec<u8>,
    pub key: Option<String>,
    pub headers: Vec<(String, String)>,
}

Message in the queue.

Fields

payload: Vec<u8>

Message payload.

key: Option<String>

Optional message key.

headers: Vec<(String, String)>

Optional headers.

Implementations

impl QueueMessage

pub fn new(payload: impl Into<Vec<u8>>) -> Self

Create a new message with payload.

pub fn from_string(s: impl Into<String>) -> Self

Create a message from a string.

pub fn from_json<T: Serialize>(value: &T) -> Result<Self>

Create a message from JSON.

pub fn with_key(self, key: impl Into<String>) -> Self

Set the message key.

pub fn with_header( self, key: impl Into<String>, value: impl Into<String>, ) -> Self

Add a header.

Trait Implementations

impl Clone for QueueMessage

fn clone(&self) -> QueueMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueueMessage

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

Formats the value using the given formatter.