Struct spartan_lib::core::message::builder::MessageBuilder

pub struct MessageBuilder { /* fields omitted */ }

Message builder

use spartan_lib::chrono::{Utc, FixedOffset};
use spartan_lib::core::message::builder::MessageBuilder;

let message = MessageBuilder::default()
    .body("Hello, world")
    .offset(9 * 3600)
    .max_tries(5)
    .timeout(60)
    .delay(10)
    .compose()
    .unwrap();

Implementations

impl MessageBuilder

#[must_use]pub fn body<T>(self, body: T) -> Self where
    T: Into<Box<str>>, 

Message body.

#[must_use]pub fn offset(self, offset: i32) -> Self

Timezone offset in seconds.

#[must_use]pub fn max_tries(self, max_tries: u32) -> Self

Max tries for message to be reserved.

#[must_use]pub fn timeout(self, timeout: u32) -> Self

Message timeout. Used by GC to collect messages that execute for too long.

#[must_use]pub fn delay(self, delay: u32) -> Self

Set message delay in seconds.

pub fn compose(self) -> Result<Message, BuilderError>

Compose message. Returns Err, if body was not provided.

Trait Implementations

impl Default for MessageBuilder

pub fn default() -> Self

Returns the "default value" for a type.