pub enum BuilderStep {
Processor(BoxProcessor),
To(String),
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,
},
}Expand description
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.
Split
A Splitter sub-pipeline: config + nested steps to execute per fragment.
Aggregate
An Aggregator step: collects exchanges by correlation key, emits when complete.
Fields
§
config: AggregatorConfigFilter
A Filter sub-pipeline: predicate + nested steps executed only when predicate is true.
Choice
A Choice step: evaluates when-clauses in order, routes to the first match. If no when matches, the optional otherwise branch is used.
WireTap
A WireTap step: sends a clone of the exchange to a tap endpoint (fire-and-forget).
Multicast
A Multicast step: sends the same exchange to multiple destinations.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for BuilderStep
impl !RefUnwindSafe for BuilderStep
impl Send for BuilderStep
impl !Sync for BuilderStep
impl Unpin for BuilderStep
impl UnsafeUnpin for BuilderStep
impl !UnwindSafe for BuilderStep
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