Struct RetryHandler 

pub struct RetryHandler { /* private fields */ }

Middleware that handles automatic retries for failed messages with exponential backoff.

Implementations

impl RetryHandler

pub fn new(config: RetryHandlerConfig) -> Self

Creates a new RetryHandler with the given configuration.

Trait Implementations

impl Middleware for RetryHandler

fn name(&self) -> &str

Get the name of this middleware for debugging and logging.

fn handle<'life0, 'async_trait>( &'life0 self, message: ReceivedMessage<Value>, next: Box<dyn MessageHandler>, ) -> Pin<Box<dyn Future<Output = Result<MiddlewareResult, WorkerError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Process a message with access to the next handler in the chain.