Module consumer

Structs§

ConsumerContext: Context provided to a Consumer, allowing it to send exchanges into the route.
ExchangeEnvelope: A message sent from a consumer to the route pipeline.
InFlightClaim: Re-export of camel_api::InFlightClaim — the context-global accepted-not-completed RAII claim (drainclaim). The canonical definition and contract live in camel_api::in_flight; this alias keeps the historical camel_component_api::consumer::InFlightClaim path stable. claimfamily: the type moved to camel-api so camel_api::Exchange can carry it for stash-site residency. One accepted-not-completed unit on the context-global in-flight counter.
SecurityContext: Security context passed to a consumer before start().
StartupReceiver: Receiver half of the consumer startup handshake. Resolves once the consumer calls ConsumerContext::mark_ready (Ok) or its start() returns an Err first (Err).
StartupSignal: Shared handle used by a Consumer to signal readiness (or failure) to the runtime’s StartupReceiver.

ConcurrencyModel: How a consumer’s exchanges should be processed by the pipeline.
ConsumerStartupMode: Declares when the runtime may consider a Consumer “started”.

Consumer: A Consumer receives data from an external system and submits Exchanges to the Route’s Pipeline via the ConsumerContext.