Struct SedaComponent 

pub struct SedaComponent { /* private fields */ }

Cloning shares the endpoint registry, so a clone registered into a CamelContext and the original handle observe the same per-endpoint state (the MockComponent pattern).

Implementations

impl SedaComponent

pub fn new() -> Self

pub fn has_active_consumer(&self, endpoint_name: &str) -> bool

True when the named endpoint has at least one consumer that has started and not yet stopped — the same signal the producer-side no-active-consumers gate checks, so polling this predicate is a side-effect-free readiness probe for senders that must not retry (a retried pipeline re-executes steps with side effects, such as route-interception divert copies). Singular: one endpoint name, unlike the per-endpoint-state has_active_consumers check. Unknown endpoint names report false.

Trait Implementations

impl Clone for SedaComponent

fn clone(&self) -> SedaComponent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Component for SedaComponent

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 SedaComponent

fn default() -> Self

Returns the “default value” for a type.