Struct DefaultRouteErrorHandler 

pub struct DefaultRouteErrorHandler { /* private fields */ }

Default implementation of RouteErrorHandler. Owns DLC producer exclusively. Encapsulates retry/onException/DLC logic.

Uses SyncBoxProcessor internally so the handler is Send + Sync as required by the RouteErrorHandler trait.

Implementations

impl DefaultRouteErrorHandler

pub fn new( dlc_producer: Option<BoxProcessor>, policies: Vec<(ExceptionPolicy, Option<BoxProcessor>)>, ) -> Self

Trait Implementations

impl RouteErrorHandler for DefaultRouteErrorHandler

fn match_policy(&self, err: &CamelError) -> Option<PolicyId>

Match a policy for the given error. Called once before retry.

fn retry_step<'life0, 'life1, 'async_trait>( &'life0 self, policy: Option<PolicyId>, step: &'life1 mut BoxProcessor, original: Exchange, error: CamelError, ) -> Pin<Box<dyn Future<Output = RetryOutcome> + Send + 'async_trait>>

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

Phase 1: Retry the failed step.

fn handle_step<'life0, 'async_trait>( &'life0 self, policy: Option<PolicyId>, exchange: Exchange, error: CamelError, ) -> Pin<Box<dyn Future<Output = Result<StepDisposition, CamelError>> + Send + 'async_trait>>

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

Phase 2: Determine step disposition after retry exhaustion.

fn handle_boundary<'life0, 'async_trait>( &'life0 self, _kind: BoundaryKind, exchange: Exchange, error: CamelError, ) -> Pin<Box<dyn Future<Output = Result<Exchange, CamelError>> + Send + 'async_trait>>

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

Handle boundary (infrastructure) errors.