Struct MessageBuilder

pub struct MessageBuilder<T>
where
    T: Task,
{ /* private fields */ }

Create a message with a custom configuration.

Implementations

impl<T> MessageBuilder<T>

where T: Task,

pub fn new(id: String) -> Self

Create a new MessageBuilder with a given task ID.

pub fn content_encoding(self, content_encoding: String) -> Self

pub fn correlation_id(self, correlation_id: String) -> Self

pub fn reply_to(self, reply_to: String) -> Self

pub fn id(self, id: String) -> Self

pub fn task(self, task: String) -> Self

pub fn lang(self, lang: String) -> Self

pub fn root_id(self, root_id: String) -> Self

pub fn parent_id(self, parent_id: String) -> Self

pub fn group(self, group: String) -> Self

pub fn meth(self, meth: String) -> Self

pub fn shadow(self, shadow: String) -> Self

pub fn retries(self, retries: u32) -> Self

pub fn argsrepr(self, argsrepr: String) -> Self

pub fn kwargsrepr(self, kwargsrepr: String) -> Self

pub fn origin(self, origin: String) -> Self

pub fn time_limit(self, time_limit: u32) -> Self

pub fn hard_time_limit(self, time_limit: u32) -> Self

pub fn eta(self, eta: DateTime<Utc>) -> Self

pub fn countdown(self, countdown: u32) -> Self

pub fn expires(self, expires: DateTime<Utc>) -> Self

pub fn expires_in(self, expires_in: u32) -> Self

pub fn params(self, params: T::Params) -> Self

pub fn build(self) -> Result<Message, ProtocolError>

Get the Message with the custom configuration.