Struct OutboundMessage 

#[non_exhaustive]
pub struct OutboundMessage {
    pub destination: String,
    pub key: Option<Vec<u8>>,
    pub payload: Vec<u8>,
    pub headers: Vec<(String, String)>,
}

One message to publish.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

destination: String

Where it goes: a subject, topic, queue or routing key.

key: Option<Vec<u8>>

The partition / ordering key, when the backend has one.

payload: Vec<u8>

The body.

headers: Vec<(String, String)>

Headers, in order.

Implementations

impl OutboundMessage

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

A message with a body and no key or headers.

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

The same message with an ordering key.

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

The same message with one more header.

Trait Implementations

impl Clone for OutboundMessage

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OutboundMessage

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

Formats the value using the given formatter.

impl Eq for OutboundMessage

impl PartialEq for OutboundMessage

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for OutboundMessage