[−][src]Struct zeebe::PublishMessageBuilder
Configuration to publish a message.
Implementations
impl PublishMessageBuilder
[src]
pub fn new(client: Client) -> Self
[src]
Create a new publish message builder.
pub fn with_name<T: Into<String>>(self, name: T) -> Self
[src]
Set the name of the message.
pub fn with_correlation_key<T: Into<String>>(self, correlation_key: T) -> Self
[src]
Set the correlation key of the message.
pub fn with_time_to_live(self, ttl: u64) -> Self
[src]
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
[src]
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
[src]
Set the JSON document representing the variables in the message.
pub async fn send(__arg0: Self) -> Result<PublishMessageResponse>
[src]
Submit the publish message request.
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for PublishMessageBuilder
impl Send for PublishMessageBuilder
impl Sync for PublishMessageBuilder
impl Unpin for PublishMessageBuilder
impl !UnwindSafe for PublishMessageBuilder
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T> Instrument for T
[src]
fn instrument(self, span: Span) -> Instrumented<Self>
[src]
fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> IntoRequest<T> for T
[src]
fn into_request(self) -> Request<T>
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,
fn vzip(self) -> V
impl<T> WithSubscriber for T
[src]
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
[src]
S: Into<Dispatch>,