Struct ErrorClassificationMiddleware 

pub struct ErrorClassificationMiddleware { /* private fields */ }

Error classification middleware for intelligent error routing

This middleware classifies errors into categories and can route messages to different queues based on error type (e.g., transient vs permanent errors).

Examples

use celers_kombu::ErrorClassificationMiddleware;

let classifier = ErrorClassificationMiddleware::new()
    .with_transient_pattern("timeout|connection")
    .with_permanent_pattern("validation|schema")
    .with_max_transient_retries(5);

Implementations

impl ErrorClassificationMiddleware

pub fn new() -> Self

Create a new error classification middleware

pub fn with_transient_pattern(self, pattern: &str) -> Self

Add a pattern for transient errors (can be retried)

pub fn with_permanent_pattern(self, pattern: &str) -> Self

Add a pattern for permanent errors (should not be retried)

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

Set maximum retries for transient errors

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

Set maximum retries for permanent errors

pub fn classify_error(&self, error_msg: &str) -> ErrorClass

Classify an error message

pub fn should_retry(&self, error_msg: &str, current_retries: u32) -> bool

Determine if a message should be retried based on error classification

Trait Implementations

impl Default for ErrorClassificationMiddleware

fn default() -> Self

Returns the “default value” for a type.

impl MessageMiddleware for ErrorClassificationMiddleware

fn before_publish<'life0, 'life1, 'async_trait>( &'life0 self, message: &'life1 mut Message, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Process message before publishing

fn after_consume<'life0, 'life1, 'async_trait>( &'life0 self, _message: &'life1 mut Message, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Process message after consuming

fn name(&self) -> &str

Get middleware name for logging