Trait hedwig::AcknowledgeToken

pub trait AcknowledgeToken {
    type AckError;
    type NackError;
    type ModifyError;
    fn ack<'async_trait>(
        self
    ) -> Pin<Box<dyn Future<Output = Result<(), Self::AckError>> + Send + 'async_trait>>
    where
        Self: 'async_trait;
    fn nack<'async_trait>(
        self
    ) -> Pin<Box<dyn Future<Output = Result<(), Self::NackError>> + Send + 'async_trait>>
    where
        Self: 'async_trait;
    fn modify_deadline<'life0, 'async_trait>(
        &'life0 mut self, 
        seconds: u32
    ) -> Pin<Box<dyn Future<Output = Result<(), Self::ModifyError>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;
}

A token associated with some message received from a message service, used to issue an ack/nack/modify request

See the documentation for acknowledging messages on Consumer

Associated Types

type AckError

Errors returned by ack

type NackError

Errors returned by nack

type ModifyError

Errors returned by modify_deadline

Required methods

fn ack<'async_trait>(
    self
) -> Pin<Box<dyn Future<Output = Result<(), Self::AckError>> + Send + 'async_trait>> where
    Self: 'async_trait, 

Acknowledge the associated message

fn nack<'async_trait>(
    self
) -> Pin<Box<dyn Future<Output = Result<(), Self::NackError>> + Send + 'async_trait>> where
    Self: 'async_trait, 

Negatively acknowledge the associated message

fn modify_deadline<'life0, 'async_trait>(
    &'life0 mut self,
    seconds: u32
) -> Pin<Box<dyn Future<Output = Result<(), Self::ModifyError>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Change the associated message’s acknowledge deadline to the given number of seconds

Implementors

impl AcknowledgeToken for AcknowledgeToken

type AckError = AcknowledgeError

type ModifyError = ModifyAcknowledgeError

type NackError = AcknowledgeError

impl AcknowledgeToken for MockAckToken

type AckError = Error

type NackError = Error

type ModifyError = Error