Struct QueueMessage 

pub struct QueueMessage {
    pub topic: String,
    pub payload: Bytes,
    pub headers: BTreeMap<String, String>,
    pub key: Option<String>,
    pub partition: Option<i32>,
    pub dead_letter: Option<DeadLetterTarget>,
    pub attributes: Value,
}

Fields

topic: String

payload: Bytes

headers: BTreeMap<String, String>

key: Option<String>

partition: Option<i32>

dead_letter: Option<DeadLetterTarget>

attributes: Value

Implementations

impl QueueMessage

pub fn new(topic: impl Into<String>, payload: impl Into<Bytes>) -> Self

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

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

pub fn with_partition(self, partition: i32) -> Self

pub fn with_dead_letter(self, target: DeadLetterTarget) -> Self

pub fn with_attributes(self, attributes: Value) -> Self

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.