Struct worker::MessageBatch

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

A batch of messages that are sent to a consumer Worker.

Implementations

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 retry_all_with_options(&self, queue_retry_options: &QueueRetryOptions)

Marks every message to be retried in the next batch with options.

pub fn ack_all(&self)

Marks every message acknowledged in the batch.

pub fn raw_iter(&self) -> RawMessageIter

Iterator for raw messages in the message batch. Ordering of messages is not guaranteed.

impl<T: DeserializeOwned> MessageBatch<T>

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

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

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

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

Trait Implementations

impl<T> From<MessageBatch> for MessageBatch<T>

fn from(value: MessageBatchSys) -> Self

Converts to this type from the input type.