Struct IdempotentConsumerStepDef 

pub struct IdempotentConsumerStepDef {
    pub repository: String,
    pub expression: LanguageExpressionDef,
    pub steps: Vec<DeclarativeStep>,
    pub eager: Option<bool>,
    pub remove_on_failure: Option<bool>,
}

Idempotent Consumer EIP step definition.

Wraps a child sub-pipeline that runs only when the exchange’s message-id is NOT already present in the named repository. See ADR-0023.

Fields

repository: String

Name of the registered IdempotentRepository (e.g. "memory").

expression: LanguageExpressionDef

Expression that extracts the message-id key from the exchange.

steps: Vec<DeclarativeStep>

Child sub-pipeline executed on first-time (non-duplicate) exchanges.

eager: Option<bool>

If true, reserve the key in the repository BEFORE running the child (eager mode). Default false (lazy: add only after the child completes).

remove_on_failure: Option<bool>

If true and eager is true, remove the key from the repository when the child returns Failed. Default false.

Trait Implementations

impl Clone for IdempotentConsumerStepDef

fn clone(&self) -> IdempotentConsumerStepDef

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for IdempotentConsumerStepDef

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PartialEq for IdempotentConsumerStepDef

fn eq(&self, other: &IdempotentConsumerStepDef) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for IdempotentConsumerStepDef