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, ) -> Self

Create a new consumer context wrapping the given channel sender.

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