Trait worker::MessageExt

source ·
pub trait MessageExt {
    // Required methods
    fn id(&self) -> String;
    fn timestamp(&self) -> Date;
    fn retry(&self);
    fn retry_with_options(&self, queue_retry_options: &QueueRetryOptions);
    fn ack(&self);
}

Required Methods§

source

fn id(&self) -> String

A unique, system-generated ID for the message.

source

fn timestamp(&self) -> Date

A timestamp when the message was sent.

source

fn retry(&self)

Marks message to be retried.

source

fn retry_with_options(&self, queue_retry_options: &QueueRetryOptions)

Marks message to be retried with options.

source

fn ack(&self)

Marks message acknowledged.

Implementors§

source§

impl<T: MessageSysInner> MessageExt for T