Struct zeebe::PublishMessageBuilder

pub struct PublishMessageBuilder { /* private fields */ }

Configuration to publish a message.

Implementations

impl PublishMessageBuilder

pub fn new(client: Client) -> Self

Create a new publish message builder.

pub fn with_name<T: Into<String>>(self, name: T) -> Self

Set the name of the message.

pub fn with_correlation_key<T: Into<String>>(self, correlation_key: T) -> Self

Set the correlation key of the message.

pub fn with_time_to_live(self, ttl: u64) -> Self

Set how long the message should be buffered on the broker, in milliseconds

pub fn with_message_id<T: Into<String>>(self, message_id: T) -> Self

Set the unique ID of the message; can be omitted. only useful to ensure only one message with the given ID will ever be published (during its lifetime)

pub fn with_variables<T: Into<Value>>(self, variables: T) -> Self

Set the JSON document representing the variables in the message.

pub async fn send(self) -> Result<PublishMessageResponse>

Submit the publish message request.

Trait Implementations

impl Debug for PublishMessageBuilder

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

Formats the value using the given formatter.