Struct CamelContext 

pub struct CamelContext { /* private fields */ }

The CamelContext is the runtime engine that manages components, routes, and their lifecycle.

Lifecycle

A CamelContext is single-use: call start() once to launch routes, then stop() or abort() to shut down. Restarting a stopped context is not supported — create a new instance instead.

Implementations

impl CamelContext

pub fn new() -> Self

Create a new, empty CamelContext.

pub fn with_metrics(metrics: Arc<dyn MetricsCollector>) -> Self

Create a new CamelContext with a custom metrics collector.

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 register_component<C: Component + 'static>(&mut self, component: C)

Register a component with this context.

pub fn register_language( &mut self, name: impl Into<String>, lang: Box<dyn Language>, ) -> Result<(), LanguageError>

Register a language with this context, keyed by name.

Returns Err(LanguageError::AlreadyRegistered) if a language with the same name is already registered. Use resolve_language to check before registering, or choose a distinct name.

pub fn resolve_language(&self, name: &str) -> Option<&dyn Language>

Resolve a language by name. Returns None if not registered.

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

Add a route definition to this context.

The route must have an ID. Steps are resolved immediately using registered components.

pub fn registry(&self) -> MutexGuard<'_, Registry>

Access the component registry.

pub fn route_controller(&self) -> &Arc<Mutex<DefaultRouteController>>

Access the route controller.

pub fn metrics(&self) -> Arc<dyn MetricsCollector>

Get the metrics collector.

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

Get the status of a route by ID.

pub async fn start(&mut self) -> Result<(), CamelError>

Start all routes. Each route’s consumer will begin producing exchanges.

Only routes with auto_startup == true will be started, in order of their startup_order (lower values start first).

pub async fn stop(&mut self) -> Result<(), CamelError>

Graceful shutdown with default 30-second timeout.

pub async fn stop_timeout( &mut self, _timeout: Duration, ) -> Result<(), CamelError>

Graceful shutdown with custom timeout.

Note: The timeout parameter is currently not used directly; the RouteController manages its own shutdown timeout. This may change in a future version.

pub async fn abort(&mut self)

Immediate abort — kills all tasks without draining.

Trait Implementations

impl Default for CamelContext

fn default() -> Self

Returns the “default value” for a type.