Struct PublishMessage 

pub struct PublishMessage { /* private fields */ }

Used for building customized publish message.

Implementations

impl PublishMessage

pub fn build() -> Self

Creates a new custom Publish struct to be used with.

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

Sets the payload for the message.

pub fn headers(self, headers: HeaderMap) -> Self

Adds headers to the message.

pub fn header<N: IntoHeaderName, V: IntoHeaderValue>( self, name: N, value: V, ) -> Self

A shorthand to add a single header.

pub fn message_id<T: AsRef<str>>(self, id: T) -> Self

Sets the Nats-Msg-Id header, that is used by stream deduplicate window.

pub fn expected_last_message_id<T: AsRef<str>>(self, last_message_id: T) -> Self

Sets expected last message ID. It sets the Nats-Expected-Last-Msg-Id header with provided value.

pub fn expected_last_sequence(self, last_sequence: u64) -> Self

Sets the last expected stream sequence. It sets the Nats-Expected-Last-Sequence header with provided value.

pub fn expected_last_subject_sequence(self, subject_sequence: u64) -> Self

Sets the last expected stream sequence for a subject this message will be published to. It sets the Nats-Expected-Last-Subject-Sequence header with provided value.

pub fn expected_stream<T: AsRef<str>>(self, stream: T) -> Self

Sets the expected stream name. It sets the Nats-Expected-Stream header with provided value.

pub fn outbound_message<S: ToSubject>(self, subject: S) -> OutboundMessage

Creates an crate::jetstream::message::OutboundMessage that can be sent using crate::jetstream::context::traits::Publisher::publish_message.

Trait Implementations

impl Clone for PublishMessage

fn clone(&self) -> PublishMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PublishMessage

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

Formats the value using the given formatter.

impl Default for PublishMessage

fn default() -> PublishMessage

Returns the “default value” for a type.