Struct hedwig::AcknowledgeableMessage

pub struct AcknowledgeableMessage<A, M> {
    pub ack_token: A,
    pub message: M,
}

A received message which can be acknowledged to prevent re-delivery by the backing message service.

See the documentation for acknowledging messages on Consumer

Fields

ack_token: A

The acknowledgement token which executes the ack/nack/modify operations

message: M

The underlying message

Implementations

impl<A, M> AcknowledgeableMessage<A, M>

where A: AcknowledgeToken,

pub async fn ack(self) -> Result<M, A::AckError>

Acknowledge this message, declaring that processing was successful and the message should not be re-delivered to consumers.

pub async fn nack(self) -> Result<M, A::NackError>

Negatively acknowledge this message, declaring that processing was unsuccessful and the message should be re-delivered to consumers.

pub async fn modify_deadline( &mut self, seconds: u32 ) -> Result<(), A::ModifyError>

Modify the acknowledgement deadline for this message to the given number of seconds.

The new deadline will typically be this number of seconds after the service receives this modification requesst, though users should check their implementation’s documented behavior.

Trait Implementations

impl<A: Debug, M: Debug> Debug for AcknowledgeableMessage<A, M>

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

Formats the value using the given formatter.

impl<A, M> Deref for AcknowledgeableMessage<A, M>

type Target = M

The resulting type after dereferencing.

fn deref(&self) -> &M

Dereferences the value.

impl<A, M> DerefMut for AcknowledgeableMessage<A, M>

fn deref_mut(&mut self) -> &mut M

Mutably dereferences the value.