Struct CamelContext 

pub struct CamelContext { /* private fields */ }

Shared state handed to components/endpoints so they can resolve other endpoints (e.g. a Producer sending into direct:next).

Implementations

impl CamelContext

pub fn new() -> Arc<Self>

pub fn register_component(&self, component: Arc<dyn Component>)

pub async fn resolve_endpoint(&self, uri_str: &str) -> Result<Arc<dyn Endpoint>>

Resolve a URI to an Endpoint, reusing any previously-created endpoint for the same URI. Creating an endpoint is cheap in MVP components, but the cache is the natural place to deduplicate direct:foo producers and consumers so they share the same channel.

pub async fn add_route(&self, route: Route)

Add a pre-built Route to the context. start() is what actually wires consumers up.

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

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

pub fn is_running(&self) -> bool

pub async fn send(&self, uri: &str, exchange: &mut Exchange) -> Result<()>

ProducerTemplate equivalent — resolve an endpoint and send a one-shot exchange. Useful for tests and for injecting messages into direct: from outside the route graph.