Struct DefaultRouteController 

pub struct DefaultRouteController { /* private fields */ }

Default implementation of RouteController.

Manages route lifecycle with support for:

• Starting/stopping individual routes
• Suspending and resuming routes
• Auto-startup with startup ordering
• Graceful shutdown

Implementations

impl DefaultRouteController

pub fn new(registry: Arc<Mutex<Registry>>) -> Self

Create a new DefaultRouteController with the given registry.

pub fn set_self_ref(&mut self, self_ref: Arc<Mutex<dyn RouteController>>)

Set the self-reference for creating ProducerContext.

This must be called after wrapping the controller in Arc<Mutex<>>.

pub fn set_error_handler(&mut self, config: ErrorHandlerConfig)

Set a global error handler applied to all routes without a per-route handler.

pub fn add_route( &mut self, definition: RouteDefinition, ) -> Result<(), CamelError>

Add a route definition to the controller.

Steps are resolved immediately using the registry.

Errors

Returns an error if:

• A route with the same ID already exists
• Step resolution fails

pub fn route_count(&self) -> usize

Returns the number of routes in the controller.

pub fn route_ids(&self) -> Vec<String>

Returns all route IDs.

pub fn swap_pipeline( &self, route_id: &str, new_pipeline: BoxProcessor, ) -> Result<(), CamelError>

Atomically swap the pipeline of a route.

In-flight requests finish with the old pipeline (kept alive by Arc). New requests immediately use the new pipeline.

pub fn route_from_uri(&self, route_id: &str) -> Option<&str>

Returns the from_uri of a route, if it exists.

pub fn get_pipeline(&self, route_id: &str) -> Option<BoxProcessor>

Get a clone of the current pipeline for a route.

This is useful for testing and introspection. Returns None if the route doesn’t exist.

Trait Implementations

impl RouteController for DefaultRouteController

fn start_route<'life0, 'life1, 'async_trait>( &'life0 mut self, route_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

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

Start a specific route by its ID.

fn stop_route<'life0, 'life1, 'async_trait>( &'life0 mut self, route_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

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

Stop a specific route by its ID.

fn restart_route<'life0, 'life1, 'async_trait>( &'life0 mut self, route_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

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

Restart a specific route by its ID.

fn suspend_route<'life0, 'life1, 'async_trait>( &'life0 mut self, route_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

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

Suspend a specific route by its ID.

fn resume_route<'life0, 'life1, 'async_trait>( &'life0 mut self, route_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

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

Resume a suspended route by its ID.

fn route_status(&self, route_id: &str) -> Option<RouteStatus>

Get the current status of a route by its ID.

fn start_all_routes<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

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

Start all routes in the context.

fn stop_all_routes<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

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

Stop all routes in the context.