Enum BuilderStep 

pub enum BuilderStep {
    Processor(BoxProcessor),
    To(String),
    Stop,
    Log {
        level: LogLevel,
        message: String,
    },
    DeclarativeSetHeader {
        key: String,
        value: ValueSourceDef,
    },
    DeclarativeSetBody {
        value: ValueSourceDef,
    },
    DeclarativeFilter {
        predicate: LanguageExpressionDef,
        steps: Vec<BuilderStep>,
    },
    DeclarativeChoice {
        whens: Vec<DeclarativeWhenStep>,
        otherwise: Option<Vec<BuilderStep>>,
    },
    DeclarativeScript {
        expression: LanguageExpressionDef,
    },
    DeclarativeSplit {
        expression: LanguageExpressionDef,
        aggregation: AggregationStrategy,
        parallel: bool,
        parallel_limit: Option<usize>,
        stop_on_exception: bool,
        steps: Vec<BuilderStep>,
    },
    Split {
        config: SplitterConfig,
        steps: Vec<BuilderStep>,
    },
    Aggregate {
        config: AggregatorConfig,
    },
    Filter {
        predicate: FilterPredicate,
        steps: Vec<BuilderStep>,
    },
    Choice {
        whens: Vec<WhenStep>,
        otherwise: Option<Vec<BuilderStep>>,
    },
    WireTap {
        uri: String,
    },
    Multicast {
        steps: Vec<BuilderStep>,
        config: MulticastConfig,
    },
    DeclarativeLog {
        level: LogLevel,
        message: ValueSourceDef,
    },
    Bean {
        name: String,
        method: String,
    },
    Script {
        language: String,
        script: String,
    },
    Throttle {
        config: ThrottlerConfig,
        steps: Vec<BuilderStep>,
    },
    LoadBalance {
        config: LoadBalancerConfig,
        steps: Vec<BuilderStep>,
    },
    DynamicRouter {
        config: DynamicRouterConfig,
    },
}

A step in an unresolved route definition.

Variants

Processor(BoxProcessor)

A pre-built Tower processor service.

To(String)

A destination URI — resolved at start time by CamelContext.

Stop

A stop step that halts processing immediately.

Log

A static log step.

Fields

level: LogLevel

message: String

DeclarativeSetHeader

Declarative set_header (literal or language-based value), resolved at route-add time.

Fields

key: String

value: ValueSourceDef

DeclarativeSetBody

Declarative set_body (literal or language-based value), resolved at route-add time.

Fields

value: ValueSourceDef

DeclarativeFilter

Declarative filter using a language predicate, resolved at route-add time.

Fields

predicate: LanguageExpressionDef

steps: Vec<BuilderStep>

DeclarativeChoice

Declarative choice/when/otherwise using language predicates, resolved at route-add time.

Fields

whens: Vec<DeclarativeWhenStep>

otherwise: Option<Vec<BuilderStep>>

DeclarativeScript

Declarative script step evaluated by language and written to body.

Fields

expression: LanguageExpressionDef

DeclarativeSplit

Declarative split using a language expression, resolved at route-add time.

Fields

expression: LanguageExpressionDef

aggregation: AggregationStrategy

parallel: bool

parallel_limit: Option<usize>

stop_on_exception: bool

steps: Vec<BuilderStep>

Split

A Splitter sub-pipeline: config + nested steps to execute per fragment.

Fields

config: SplitterConfig

steps: Vec<BuilderStep>

Aggregate

An Aggregator step: collects exchanges by correlation key, emits when complete.

Fields

config: AggregatorConfig

Filter

A Filter sub-pipeline: predicate + nested steps executed only when predicate is true.

Fields

predicate: FilterPredicate

steps: Vec<BuilderStep>

Choice

A Choice step: evaluates when-clauses in order, routes to the first match. If no when matches, the optional otherwise branch is used.

Fields

whens: Vec<WhenStep>

otherwise: Option<Vec<BuilderStep>>

WireTap

A WireTap step: sends a clone of the exchange to a tap endpoint (fire-and-forget).

Fields

uri: String

Multicast

A Multicast step: sends the same exchange to multiple destinations.

Fields

steps: Vec<BuilderStep>

config: MulticastConfig

DeclarativeLog

Declarative log step with a language-evaluated message, resolved at route-add time.

Fields

level: LogLevel

message: ValueSourceDef

Bean

Bean invocation step — resolved at route-add time.

Fields

name: String

method: String

Script

Script step: executes a script that can mutate the exchange. The script has access to headers, properties, and body.

Fields

language: String

script: String

Throttle

Throttle step: rate limiting with configurable behavior when limit exceeded.

Fields

config: ThrottlerConfig

steps: Vec<BuilderStep>

LoadBalance

LoadBalance step: distributes exchanges across multiple endpoints using a strategy.

Fields

config: LoadBalancerConfig

steps: Vec<BuilderStep>

DynamicRouter

DynamicRouter step: routes exchanges dynamically based on expression evaluation.

Fields

config: DynamicRouterConfig

Trait Implementations

impl Debug for BuilderStep

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

Formats the value using the given formatter.