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 with_beans( registry: Arc<Mutex<Registry>>, beans: Arc<Mutex<BeanRegistry>>, ) -> Self

Create a new DefaultRouteController with shared bean registry.

pub fn with_languages( registry: Arc<Mutex<Registry>>, languages: SharedLanguageRegistry, ) -> Self

Create a new DefaultRouteController with shared language 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_runtime_handle(&mut self, runtime: Arc<dyn RuntimeHandle>)

Set runtime handle for ProducerContext creation.

pub fn self_ref_for_supervision( &self, ) -> Option<Arc<Mutex<dyn RouteController>>>

Get the self-reference, if set.

Used by SupervisingRouteController to spawn the supervision loop.

pub fn runtime_handle_for_supervision(&self) -> Option<Arc<dyn RuntimeHandle>>

Get runtime handle for supervision-triggered lifecycle commands, if set.

pub fn set_crash_notifier(&mut self, tx: Sender<CrashNotification>)

Set the crash notifier for supervision.

When set, the controller will send a CrashNotification whenever a consumer crashes.

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 set_tracer_config(&mut self, config: &TracerConfig)

Configure tracing for this route controller.

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 compile_route_definition( &self, def: RouteDefinition, ) -> Result<BoxProcessor, CamelError>

Compile a RouteDefinition into a BoxProcessor without inserting into the route map.

Used by hot-reload to prepare a new pipeline for atomic swap without disrupting the running route. The caller is responsible for swapping via swap_pipeline.

pub fn remove_route(&mut self, route_id: &str) -> Result<(), CamelError>

Remove a route from the controller map.

The route must be stopped before removal (status Stopped or Failed). Returns an error if the route is still running or does not exist. Does not cancel any running tasks — call stop_route first.

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 auto_startup_route_ids(&self) -> Vec<String>

Returns route IDs that should auto-start, sorted by startup order (ascending).

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

Returns route IDs sorted by shutdown order (startup order descending).

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<String>

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 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.

impl RouteControllerInternal for DefaultRouteController

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

Add a route definition to the controller.

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

Atomically swap the pipeline of a running route (for hot-reload).

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

Returns the from_uri of a route by ID.

fn set_error_handler(&mut self, config: ErrorHandlerConfig)

Set a global error handler applied to all routes.

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

Set the self-reference needed to create ProducerContext.

fn set_runtime_handle(&mut self, runtime: Arc<dyn RuntimeHandle>)

Set runtime handle for ProducerContext command/query access.

fn route_count(&self) -> usize

Returns the number of routes in the controller.

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

Returns all route IDs.

fn auto_startup_route_ids(&self) -> Vec<String>

Returns route IDs that should auto-start, sorted by startup order (ascending).

fn shutdown_route_ids(&self) -> Vec<String>

Returns route IDs sorted by shutdown order (startup order descending).

fn set_tracer_config(&mut self, config: &TracerConfig)

Configure tracing from a TracerConfig.

fn compile_route_definition( &self, def: RouteDefinition, ) -> Result<BoxProcessor, CamelError>

Compile a RouteDefinition into a BoxProcessor without inserting it into the route map. Used by hot-reload to prepare a new pipeline for atomic swap.

fn remove_route(&mut self, route_id: &str) -> Result<(), CamelError>

Remove a route from the controller map (route must be stopped first).

fn start_route_reload<'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 route by ID (for use by hot-reload, where async_trait is required).

fn stop_route_reload<'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 route by ID (for use by hot-reload, where async_trait is required).