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.

Runtime state is in-memory/ephemeral by default.

pub fn new_with_runtime_journal_path(path: impl Into<PathBuf>) -> Self

Create a new CamelContext with an explicit runtime journal file path.

This opt-in path enables local runtime replay/durability semantics.

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

Create a new CamelContext with a custom metrics collector.

pub fn with_metrics_and_runtime_journal_path( metrics: Arc<dyn MetricsCollector>, journal_path: impl Into<PathBuf>, ) -> Self

Create a new CamelContext with custom metrics and explicit runtime journal file path.

pub fn with_supervision(config: SupervisionConfig) -> Self

Create a new CamelContext with route supervision enabled.

The supervision config controls automatic restart behavior for crashed routes.

pub fn with_supervision_and_metrics( config: SupervisionConfig, metrics: Arc<dyn MetricsCollector>, ) -> Self

Create a new CamelContext with route supervision and custom metrics.

The supervision config controls automatic restart behavior for crashed routes.

pub fn with_supervision_and_metrics_and_runtime_journal_path( config: SupervisionConfig, metrics: Arc<dyn MetricsCollector>, journal_path: impl Into<PathBuf>, ) -> Self

Create a new CamelContext with supervision, custom metrics, and explicit journal path.

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_tracing(&mut self, enabled: bool)

Enable or disable tracing globally.

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

Configure tracing with full config.

pub fn with_tracing(self) -> Self

Builder-style: enable tracing with default config.

pub fn with_tracer_config(self, config: TracerConfig) -> Self

Builder-style: configure tracing with custom config. Note: tracing subscriber initialization (stdout/file output) is handled separately via init_tracing_subscriber (called in camel-config bridge).

pub fn with_lifecycle<L: Lifecycle + 'static>(self, service: L) -> Self

Register a lifecycle service (Apache Camel: addService pattern)

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<Arc<dyn Language>>

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

pub async fn add_route_definition( &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 runtime_execution_handle(&self) -> RuntimeExecutionHandle

Get runtime execution handle for file-watcher integrations.

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

Get the metrics collector.

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

Get runtime command/query bus handle.

pub fn producer_context(&self) -> ProducerContext

Build a producer context wired to this runtime.

pub async fn runtime_route_status( &self, route_id: &str, ) -> Result<Option<String>, CamelError>

Query route status via runtime read-model.

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 fn shutdown_timeout(&self) -> Duration

Get the graceful shutdown timeout used by stop().

pub fn set_shutdown_timeout(&mut self, timeout: Duration)

Set the graceful shutdown timeout used by stop().

pub async fn abort(&mut self)

Immediate abort — kills all tasks without draining.

pub fn health_check(&self) -> HealthReport

Check health status of all registered services.

pub fn set_component_config<T: 'static + Send + Sync>(&mut self, config: T)

Store a component config. Overwrites any previously stored config of the same type.

pub fn get_component_config<T: 'static + Send + Sync>(&self) -> Option<&T>

Retrieve a stored component config by type. Returns None if not stored.

Trait Implementations

impl Default for CamelContext

fn default() -> Self

Returns the “default value” for a type.