Struct RetryHandlerConfig 

pub struct RetryHandlerConfig {
    pub max_retries: u32,
    pub initial_backoff: Duration,
    pub max_backoff: Duration,
    pub backoff_multiplier: f64,
    pub dead_letter_queue: Option<Arc<DeadLetterQueueBackend>>,
    pub poison_pill_tracker: Option<Arc<PoisonPillTracker>>,
    pub use_jitter: bool,
}

Configuration for the RetryHandler middleware.

Fields

max_retries: u32

The maximum number of times a message should be retried.

initial_backoff: Duration

The initial backoff duration for the first retry.

max_backoff: Duration

The maximum backoff duration.

backoff_multiplier: f64

Multiplier for exponential backoff.

dead_letter_queue: Option<Arc<DeadLetterQueueBackend>>

Optional dead letter queue backend for permanently failed messages.

poison_pill_tracker: Option<Arc<PoisonPillTracker>>

Optional poison pill tracker for detecting problematic messages.

use_jitter: bool

Whether to add jitter to backoff delays (recommended for distributed systems).

Implementations

impl RetryHandlerConfig

pub fn with_max_retries(self, max_retries: u32) -> Self

Create a new config with custom max retries.

pub fn with_dead_letter_queue(self, dlq: Arc<DeadLetterQueueBackend>) -> Self

Set the dead letter queue for permanently failed messages.

pub fn with_poison_pill_tracker(self, tracker: Arc<PoisonPillTracker>) -> Self

Set the poison pill tracker for detecting problematic messages.

pub fn with_jitter(self, use_jitter: bool) -> Self

Enable or disable jitter (enabled by default).

Trait Implementations

impl Clone for RetryHandlerConfig

fn clone(&self) -> RetryHandlerConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RetryHandlerConfig

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

Formats the value using the given formatter.

impl Default for RetryHandlerConfig

fn default() -> Self

Returns the “default value” for a type.