Struct RetryConfig 

pub struct RetryConfig {
    pub max_retries: u32,
    pub mechanism: RetryMechanism,
    pub dead_letter_exchange: Option<String>,
    pub dead_letter_queue: Option<String>,
}

Simple retry configuration

Fields

max_retries: u32

Maximum number of retry attempts (0 means no retries)

mechanism: RetryMechanism

Retry mechanism to use

dead_letter_exchange: Option<String>

Dead letter exchange for messages that exceed max retries If None, uses default: “{queue_name}.dlx”

dead_letter_queue: Option<String>

Dead letter queue for permanently failed messages If None, uses default: “{queue_name}.dlq”

Implementations

impl RetryConfig

pub fn exponential_default() -> Self

Create exponential retry: 1s -> 2s -> 4s -> 8s -> 16s (max 5 retries)

pub fn exponential( max_retries: u32, base_delay: Duration, max_delay: Duration, ) -> Self

Create exponential retry with custom parameters

pub fn linear(max_retries: u32, delay: Duration) -> Self

Create linear retry: same delay for each attempt

pub fn custom(delays: Vec<Duration>) -> Self

Create custom retry with specific delays for each attempt

pub fn no_retry() -> Self

No retries - fail immediately

pub fn with_dead_letter(self, exchange: String, queue: String) -> Self

Set custom dead letter exchange and queue names

pub fn calculate_delay(&self, attempt: u32) -> Option<Duration>

Calculate delay for a specific retry attempt (0-indexed)

pub fn get_dead_letter_exchange(&self, queue_name: &str) -> String

Get dead letter exchange name (with fallback to default)

pub fn get_dead_letter_queue(&self, queue_name: &str) -> String

Get dead letter queue name (with fallback to default)

pub fn get_retry_queue_name(&self, queue_name: &str, attempt: u32) -> String

Generate retry queue name for delayed messages

Trait Implementations

impl Clone for RetryConfig

fn clone(&self) -> RetryConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RetryConfig

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

Formats the value using the given formatter.

impl Default for RetryConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for RetryConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for RetryConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.