Enum amqp_manager::AmqpConsumerError

pub enum AmqpConsumerError {
    RecoverableError(String),
    UnrecoverableError(String),
    DuplicatedEventError(String),
}

The error type returned in the AmqpConsumerResult<T> struct.

Variants

RecoverableError(String)

UnrecoverableError(String)

DuplicatedEventError(String)

Implementations

impl AmqpConsumerError

pub fn nack_options(error: &Self) -> BasicNackOptions

A helper method that returns a BasicNackOptions instance depending on the error type. Example: channel.basic_nack(delivery_tag, error::nack_options()).map(|_| ()).await.

Trait Implementations

impl Debug for AmqpConsumerError

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

Formats the value using the given formatter.