pub struct ExchangeEnvelope {
pub exchange: Exchange,
pub reply_tx: Option<Sender<Result<Exchange, CamelError>>>,
pub in_flight_claim: Option<InFlightClaim>,
}Expand description
A message sent from a consumer to the route pipeline.
Fire-and-forget exchanges use reply_tx = None.
Request-reply exchanges (e.g. direct:) provide a reply_tx so the
pipeline result can be sent back to the consumer.
Fields§
§exchange: Exchange§reply_tx: Option<Sender<Result<Exchange, CamelError>>>§in_flight_claim: Option<InFlightClaim>RAII claim on the context-global accepted-not-completed counter,
attached at acceptance boundaries (ConsumerContext::send /
send_and_wait, seda enqueue, inline dispatch). None on the raw
sender() fast path — a documented uncounted exception (drainclaim).
Auto Trait Implementations§
impl !Freeze for ExchangeEnvelope
impl !RefUnwindSafe for ExchangeEnvelope
impl !UnwindSafe for ExchangeEnvelope
impl Send for ExchangeEnvelope
impl Sync for ExchangeEnvelope
impl Unpin for ExchangeEnvelope
impl UnsafeUnpin for ExchangeEnvelope
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more