Crate camel_component_seda 

In-memory SEDA component for rust-camel — asynchronous staging channel between routes sharing the same context via bounded queues.

Main types: SedaComponent, SedaEndpoint, SedaConsumer, SedaProducer.

Structs

SedaComponent

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).

SedaConfig

Configuration parsed from a SEDA URI.

Enums

ExchangePattern

WaitForTaskToComplete

Functions

is_no_active_consumers_gate

True for the SEDA producer’s startup-race rejections: the pre-enqueue gate that fires when no consumer has started yet — Single mode’s “has no active consumers” and Fanout mode’s “has no active subscribers” (the error variant is shared EndpointCreationFailed, so the wording is the discriminator; this crate owns the message text). Both reject BEFORE enqueue but INSIDE the caller’s pipeline: steps that already ran (e.g. route-interception divert copies) have executed, so RETRYING the send duplicates their side effects. Senders that must not retry use this predicate to fail fast instead (rc-zjrx); readiness probing with SedaComponent::has_active_consumer avoids the error up front.