Struct MessageBuilder 

pub struct MessageBuilder<'a> { /* private fields */ }

Producer-bound counterpart to OutgoingMessage. Mirrors Java’s TypedMessageBuilder — the producer is captured at construction so the terminal send() has no extra argument.

Implementations

impl MessageBuilder<'_>

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

Set the routing key. See OutgoingMessage::key.

pub fn ordering_key(self, key: impl Into<Bytes>) -> Self

Set the ordering key. See OutgoingMessage::ordering_key.

pub fn event_time_ms(self, ts: u64) -> Self

Set the event time (millis since epoch). See OutgoingMessage::event_time_ms.

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

Append a property. See OutgoingMessage::property.

pub fn deliver_at_ms(self, ts_ms: i64) -> Self

See OutgoingMessage::deliver_at_ms.

pub fn deliver_after_ms(self, now_ms: i64, delay_ms: i64) -> Self

See OutgoingMessage::deliver_after_ms. The caller supplies now_ms (sans-io, ADR-0011 invariant #3); the engine convenience methods snapshot the host wall clock on the tokio path and the virtual wall clock on the moonpool path.

pub fn replication_clusters(self, clusters: Vec<String>) -> Self

See OutgoingMessage::replication_clusters.

pub fn disable_replication(self) -> Self

See OutgoingMessage::disable_replication.

pub fn txn(self, txn_id: TxnId) -> Self

See OutgoingMessage::txn.

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

Set the payload bytes. See OutgoingMessage::value.

pub fn send(self) -> SendFut

Submit the message to the producer captured at new_message() time. Mirrors Java’s terminal TypedMessageBuilder#send.

Trait Implementations

impl<'a> Debug for MessageBuilder<'a>

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

Formats the value using the given formatter.