Struct IdempotentConsumerSegment 

pub struct IdempotentConsumerSegment { /* private fields */ }

Outcome-aware Idempotent Consumer segment.

Wraps a child sub-pipeline (OutcomeSegment) and a named IdempotentRepository. On each exchange:

1. Extract message-id via message_id(&exchange). None → forward to child.
2. Check repo.contains(&key):
   • Ok(true) → duplicate, return Completed(exchange) (skip child).
   • Ok(false) → proceed.
   • Err(e) → Failed(e) (contract C1).
3. If eager: repo.add(&key) before child. Ok(false) = race duplicate → Completed. Err → Failed.
4. Run child pipeline.
5. Post-child:
   • Completed + non-eager → repo.add(&key) (best-effort).
   • Stopped → no add (pipeline terminating).
   • Failed + eager + remove_on_failure → repo.remove(&key) (best-effort).

Eager mode + Stopped

In eager mode, the key is added BEFORE the child pipeline runs. If the child returns Stopped, the key remains registered — subsequent deliveries of the same message ID are treated as duplicates and return Completed immediately. This is intentional: a Stop indicates the route chose to terminate, and re-processing the same message would be incorrect.

Implementations

impl IdempotentConsumerSegment

pub fn new( repository: Arc<dyn IdempotentRepository>, message_id: MessageIdExpression, child_pipeline: OutcomeSegment, eager: bool, remove_on_failure: bool, ) -> Self

Build a new segment from a resolved repository, message-id extractor, child sub-pipeline, and behaviour flags.

Trait Implementations

impl Clone for IdempotentConsumerSegment

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl OutcomePipeline for IdempotentConsumerSegment

fn clone_box(&self) -> Box<dyn OutcomePipeline>

Clone the segment into a new boxed instance. Required because Box<dyn OutcomePipeline> cannot directly derive Clone.

fn run<'a>( &'a mut self, exchange: Exchange, ) -> Pin<Box<dyn Future<Output = PipelineOutcome> + Send + 'a>>

Execute the segment against exchange, returning a PipelineOutcome.