Struct MessageBuilder

pub struct MessageBuilder { /* private fields */ }

Implementations

impl MessageBuilder

pub fn new() -> Self

pub fn qos(self, qos: QoS) -> Self

pub fn payload<B: Into<Bytes>>(self, payload: B) -> Self

pub fn topic<S: Into<String>>(self, topic: S) -> Self

pub fn retained(self, retain: bool) -> Self

pub fn message_expiry_interval(self, expiry_interval: Option<Duration>) -> Self

pub fn response_topic<S: Into<String>>(self, response_topic: Option<S>) -> Self

pub fn utf8(self, is_utf8: bool) -> Self

Set Payload Format Indicator to 1 (UTF-8 Encoded Character Data) or None (unspecified bytes)

pub fn add_user_property<K: Into<String>, V: Into<String>>( self, key: K, value: V, ) -> Self

pub fn correlation_data<B: Into<Bytes>>( self, correlation_data: Option<B>, ) -> Self

pub fn finalize(self) -> Message

Trait Implementations

impl Debug for MessageBuilder

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

Formats the value using the given formatter.

impl Default for MessageBuilder

fn default() -> Self

Returns the “default value” for a type.