Struct ConsumerContext 

pub struct ConsumerContext { /* private fields */ }

Context provided to a Consumer, allowing it to send exchanges into the route.

Implementations

impl ConsumerContext

pub fn new( sender: Sender<ExchangeEnvelope>, cancel_token: CancellationToken, route_id: String, ) -> Self

Create a new consumer context wrapping the given channel sender.

The route_id identifies the route this consumer is bound to, enabling ADR-0012 per-route metrics and health observations.

pub async fn cancelled(&self)

Returns a future that resolves when shutdown is requested. Use in tokio::select! inside consumer loops.

pub fn is_cancelled(&self) -> bool

Returns true if shutdown has been requested.

pub fn route_id(&self) -> &str

Returns the route_id this consumer is bound to.

Available for ADR-0012 metrics/health calls that require a route_id (categories (b′), (e), (g)). Set at construction time by the route controller when spawning the consumer task.

pub fn cancel_token(&self) -> CancellationToken

Returns a clone of the CancellationToken.

Useful for consumers that spawn per-request tasks and need to propagate shutdown to each task. See HttpConsumer for an example.

pub fn sender(&self) -> Sender<ExchangeEnvelope>

Returns a clone of the channel sender for manual exchange submission.

Useful for consumers that spawn per-request tasks (e.g., HttpConsumer) where each task independently sends exchanges into the pipeline. For simple consumers, prefer send() or send_and_wait() instead.

pub async fn send(&self, exchange: Exchange) -> Result<(), CamelError>

Send an exchange into the route pipeline (fire-and-forget).

pub async fn send_and_wait( &self, exchange: Exchange, ) -> Result<Exchange, CamelError>

Send an exchange and wait for the pipeline result (request-reply).

Returns Ok(exchange) on success or Err(e) if the pipeline failed without an error handler absorbing the error.

Trait Implementations

impl Clone for ConsumerContext

fn clone(&self) -> ConsumerContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.