Struct MockComponent 

pub struct MockComponent { /* private fields */ }

The Mock component is a testing utility that records every exchange it receives via its producer. It exposes helpers to inspect and assert on the recorded exchanges.

URI format: mock:name[?retain=N&copy=true|false&failFast=true|false&expectedCount=N&anyOrder=true|false]

URI params override the component-level MockConfig fields; absent params fall back to them. All params are optional.

When create_endpoint is called multiple times with the same name, the returned endpoints share the same received-exchanges storage and the first creation’s configuration wins — later calls with different params do not reconfigure the existing endpoint. This enables test assertions: create mock, register it, run routes, then inspect via component.get_endpoint("name").

Implementations

impl MockComponent

pub fn new() -> MockComponent

pub fn with_config(config: MockConfig) -> MockComponent

Create a MockComponent with a custom MockConfig.

pub fn get_endpoint(&self, name: &str) -> Option<Arc<MockEndpointInner>>

Retrieve a previously created endpoint’s inner data by name.

This is the primary way to inspect recorded exchanges in tests.

pub fn ensure_arrival_notify(&self, name: &str) -> Arc<Notify>

Return the arrival-notification slot for name, inserting a fresh one if absent.

The slot exists from this first request — independent of endpoint creation (the slot is keyed separately from the endpoint registry), so settle registration must not depend on endpoint existence. The record path pings the slot on every receive for name, auto-creating it when no registration preceded the receive. The registry is shared across MockComponent clones.

Trait Implementations

impl Clone for MockComponent

fn clone(&self) -> MockComponent

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Component for MockComponent

fn scheme(&self) -> &str

The URI scheme this component handles (e.g., “timer”, “log”).

fn metadata(&self) -> ComponentMetadata

Declare this component’s metadata (URI options, capabilities, version).

fn create_endpoint( &self, uri: &str, _ctx: &dyn ComponentContext, ) -> Result<Box<dyn Endpoint>, CamelError>

Create an endpoint from a URI string.

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

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

Start the component (e.g. connect to external systems).

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

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

Stop the component (e.g. release resources, close connections).

impl Default for MockComponent

fn default() -> MockComponent

Returns the “default value” for a type.