Struct PooledMessage 

pub struct PooledMessage { /* private fields */ }

A pooled message that automatically returns to the pool when dropped

Provides deref access to the underlying message.

Implementations

impl PooledMessage

pub fn take(self) -> Message

Take ownership of the message, removing it from pool management

pub fn get(&self) -> &Message

Get a reference to the message

pub fn get_mut(&mut self) -> &mut Message

Get a mutable reference to the message

Methods from Deref<Target = Message>

pub fn validate(&self) -> Result<(), ValidationError>

Validate the complete message

Validates:

• Headers (task name, retries, eta/expires)
• Properties (delivery mode, priority)
• Content type format
• Body size

pub fn validate_with_limit( &self, max_body_bytes: usize, ) -> Result<(), ValidationError>

Validate with custom body size limit

pub fn has_eta(&self) -> bool

Check if the message has an ETA (delayed execution)

pub fn has_expires(&self) -> bool

Check if the message has an expiration time

pub fn has_group(&self) -> bool

Check if the message is part of a group

pub fn has_parent(&self) -> bool

Check if the message has a parent task

pub fn has_root(&self) -> bool

Check if the message has a root task

pub fn is_persistent(&self) -> bool

Check if the message is persistent

pub fn task_id(&self) -> Uuid

Get the task ID

pub fn task_name(&self) -> &str

Get the task name

pub fn content_type_str(&self) -> &str

Get the content type as a string slice

pub fn content_encoding_str(&self) -> &str

Get the content encoding as a string slice

pub fn body_size(&self) -> usize

Get the message body size in bytes

pub fn has_empty_body(&self) -> bool

Check if the message body is empty

pub fn retry_count(&self) -> u32

Get the retry count (0 if not set)

pub fn priority(&self) -> Option<u8>

Get the priority (None if not set)

pub fn has_correlation_id(&self) -> bool

Check if message has a correlation ID

pub fn correlation_id(&self) -> Option<&str>

Get the correlation ID

pub fn reply_to(&self) -> Option<&str>

Get the reply-to queue

pub fn is_workflow_message(&self) -> bool

Check if this is a workflow message (has parent, root, or group)

pub fn with_new_id(&self) -> Self

Clone the message with a new task ID

pub fn to_builder(&self) -> MessageBuilder

Create a builder from this message (for modification)

Note: This creates a new builder with the message’s metadata. The body (args/kwargs) must be set separately on the builder.

pub fn is_ready_for_execution(&self) -> bool

Check if the message is ready for immediate execution (not delayed)

pub fn is_not_expired(&self) -> bool

Check if the message has not expired yet

pub fn should_process(&self) -> bool

Check if the message should be processed (not expired and ready for execution)

pub fn time_until_eta(&self) -> Option<Duration>

Get the time remaining until ETA (None if no ETA or already past)

pub fn time_until_expiration(&self) -> Option<Duration>

Get the time remaining until expiration (None if no expiration or already expired)

pub fn increment_retry(&mut self) -> u32

Increment the retry count (returns new count)

Trait Implementations

impl Deref for PooledMessage

type Target = Message

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl DerefMut for PooledMessage

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

impl Drop for PooledMessage

fn drop(&mut self)

Executes the destructor for this type.