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.

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.