Struct ReceivedMessage 

pub struct ReceivedMessage<T> {
    pub message: Message<T>,
    pub ack_handle: Arc<dyn AckHandle>,
}

Wrapper combining message data with acknowledgment capability.

This is what workers and middleware actually receive. It separates the pure message data from the acknowledgment operations, preventing circular dependencies while providing safe concurrent access.

Example

use foxtive_worker::message::ReceivedMessage;

async fn process_message(received: ReceivedMessage<serde_json::Value>) {
    // Access message data
    println!("Processing message: {}", received.message.id);
     
    // Process the message...
     
    // Acknowledge on success
    if let Err(e) = received.ack().await {
        eprintln!("Failed to ack: {}", e);
    }
}

Fields

message: Message<T>

The pure message data

ack_handle: Arc<dyn AckHandle>

Backend-specific acknowledgment handle (using Arc for shareability)

Implementations

impl<T: Send + Sync> ReceivedMessage<T>

pub fn new(message: Message<T>, ack_handle: Arc<dyn AckHandle>) -> Self

Create a new ReceivedMessage.

pub async fn ack(&self) -> WorkerResult<()>

Acknowledge successful message processing.

pub async fn nack(&self, requeue: bool) -> WorkerResult<()>

Negative acknowledge message processing failure.

pub fn into_message(self) -> Message<T>

Extract the inner message, discarding the ack handle.

impl ReceivedMessage<Value>

Specialized implementation for JSON messages

pub async fn retry_with_delay(&self, delay_ms: u64) -> WorkerResult<()>

Retry message with a delay (if supported by backend).

pub async fn send_to_dlq(&self, error_message: &str) -> WorkerResult<()>

Send message to Dead Letter Queue after retries are exhausted.

Trait Implementations

impl<T: Clone + Send + Sync> Clone for ReceivedMessage<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for ReceivedMessage<T>

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

Formats the value using the given formatter.