Crate coreon_eip 

camel-eip — Enterprise Integration Patterns implemented as Processors.

Re-exports

pub use aggregator::Aggregator;

pub use aggregator::AggregatorConfig;

pub use choice::Choice;

pub use choice::WhenClause;

pub use delay::DelayBy;

pub use filter::Filter;

pub use idempotent::IdempotentConsumer;

pub use load_balancer::Failover;

pub use load_balancer::RoundRobin;

pub use multicast::Multicast;

pub use on_exception::OnException;

pub use on_exception::RedeliveryPolicy;

pub use pipeline::Pipeline;

pub use recipient_list::RecipientList;

pub use splitter::Splitter;

pub use throttle::Throttle;

pub use to::To;

pub use transform::Transform;

pub use wiretap::WireTap;

Modules

aggregator

Aggregator — group exchanges by a correlation key, combine them via a user-supplied function, and emit the combined exchange once completion fires.

choice

Choice — evaluate predicates in order; run the first matching branch, or the otherwise branch if none match. If no otherwise is set, the exchange passes through unchanged.

delay

DelayBy — sleep for a fixed duration before continuing.

filter

Filter — drop the exchange if the predicate does not match.

idempotent

IdempotentConsumer — suppress exchanges whose extracted key has been seen.

load_balancer

LoadBalancer — distribute exchanges across processors.

multicast

Multicast — run N processors, each on a clone of the exchange, in parallel.

on_exception

OnException — wrap a processor with a retry policy and a dead-letter fallback.

pipeline

Pipeline — sequential composition of Processors.

recipient_list

RecipientList — compute recipient URIs from the exchange at runtime and send to each, sequentially.

splitter

Splitter — split an exchange’s body into N items; run the sub-pipeline once per item. Matches Camel’s split().body() pattern.

throttle

Throttle — allow at most max exchanges per period, blocking callers when the window is full.

to

To — send the current Exchange to another endpoint.

transform

Transform — apply a pure function to the in-message body.

wiretap

WireTap — send a clone of the exchange to another endpoint, fire-and-forget.