Struct BrokerMessage 

pub struct BrokerMessage {
    pub task: SerializedTask,
    pub receipt_handle: Option<String>,
}

Message envelope for broker operations

Fields

task: SerializedTask

The serialized task

receipt_handle: Option<String>

Receipt handle for acknowledging/rejecting the message

Implementations

impl BrokerMessage

pub const fn new(task: SerializedTask) -> Self

Create a new broker message

pub const fn with_receipt_handle( task: SerializedTask, receipt_handle: String, ) -> Self

Create a new broker message with a receipt handle

pub const fn has_receipt_handle(&self) -> bool

Check if message has a receipt handle

pub const fn task_id(&self) -> TaskId

Get task ID

pub fn task_name(&self) -> &str

Get task name

pub const fn priority(&self) -> i32

Get task priority

pub fn is_expired(&self) -> bool

Check if task is expired

pub fn age(&self) -> Duration

Get task age

Trait Implementations

impl Clone for BrokerMessage

fn clone(&self) -> BrokerMessage

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for BrokerMessage

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Display for BrokerMessage

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.