Struct worker::MessageBatch

pub struct MessageBatch<T> { /* private fields */ }

Implementations

impl<T> MessageBatch<T>

pub fn new(message_batch_sys: MessageBatchSys) -> Self

impl<T> MessageBatch<T>

pub fn queue(&self) -> String

The name of the Queue that belongs to this batch.

pub fn retry_all(&self)

Marks every message to be retried in the next batch.

pub fn iter(&self) -> MessageIter<'_, T>

where T: DeserializeOwned,

Iterator that deserializes messages in the message batch. Ordering of messages is not guaranteed.

pub fn messages(&self) -> Result<Vec<Message<T>>>

where T: DeserializeOwned,

An array of messages in the batch. Ordering of messages is not guaranteed.