Skip to main content

camel_processor/
lib.rs

1pub mod aggregator;
2pub mod choice;
3pub mod circuit_breaker;
4pub mod content_enricher;
5pub mod convert_body;
6pub mod data_format;
7pub mod delayer;
8pub mod do_try;
9pub mod do_try_segment;
10pub mod dynamic_router;
11pub mod dynamic_set_header;
12pub mod dynamic_set_property;
13pub mod endpoint_pipeline;
14pub mod enrichment_strategy;
15pub mod error_handler;
16pub mod filter;
17pub mod load_balancer;
18pub mod log;
19pub mod loop_eip;
20pub mod map_body;
21pub mod marshal;
22pub mod multicast;
23pub mod multicast_segment;
24pub mod recipient_list;
25pub mod routing_slip;
26pub mod script_mutator;
27pub mod security_policy_layer;
28pub mod set_body;
29pub mod set_header;
30pub mod set_property;
31pub mod split_segment;
32pub mod splitter;
33pub mod stream_cache;
34pub mod stream_codec;
35pub mod streaming_split_segment;
36pub mod streaming_splitter;
37pub mod throttler;
38pub mod wire_tap;
39pub mod zip_splitter;
40
41pub use aggregator::AggregatorService;
42pub use choice::{ChoiceSegment, ChoiceService, WhenClause, WhenClauseSegment};
43pub use circuit_breaker::{
44    CircuitBreakerDecision, CircuitBreakerGate, CircuitBreakerLayer, CircuitBreakerService,
45};
46pub use content_enricher::{EnrichService, PollEnrichService};
47pub use convert_body::ConvertBodyTo;
48pub use data_format::{JsonDataFormat, XmlDataFormat, ZipDataFormat, builtin_data_format};
49pub use delayer::DelayerService;
50pub use do_try::{CatchClause, CatchMatcher, DoTryService};
51pub use do_try_segment::{CatchClauseSegment, DoTrySegment, FinallyClauseSegment};
52pub use dynamic_router::DynamicRouterService;
53pub use dynamic_set_header::{DynamicSetHeader, DynamicSetHeaderLayer};
54pub use dynamic_set_property::{DynamicSetProperty, DynamicSetPropertyLayer};
55pub use endpoint_pipeline::EndpointPipelineService;
56pub use enrichment_strategy::{EnrichmentStrategy, UseEnrichedBody};
57#[rustfmt::skip]
58#[allow(deprecated)]
59pub use error_handler::{
60    DefaultRouteErrorHandler, ErrorHandlerLayer, ErrorHandlerService, RouteErrorHandler,
61    invoke_processor,
62};
63pub use filter::{FilterSegment, FilterService};
64pub use load_balancer::{LoadBalanceSegment, LoadBalancerService};
65pub use log::{LogLevel, LogProcessor};
66pub use loop_eip::{CAMEL_LOOP_INDEX, CAMEL_LOOP_SIZE, LoopSegment, LoopService};
67pub use map_body::{MapBody, MapBodyLayer};
68pub use marshal::{MarshalService, UnmarshalService};
69pub use multicast::{CAMEL_MULTICAST_COMPLETE, CAMEL_MULTICAST_INDEX, MulticastService};
70pub use multicast_segment::MulticastSegment;
71pub use recipient_list::RecipientListService;
72pub use routing_slip::RoutingSlipService;
73pub use script_mutator::ScriptMutator;
74pub use security_policy_layer::{SecurityPolicyLayer, SecurityPolicyService};
75pub use set_body::{SetBody, SetBodyLayer};
76pub use set_header::{SetHeader, SetHeaderLayer};
77pub use set_property::{SetProperty, SetPropertyLayer};
78pub use split_segment::SplitSegment;
79pub use splitter::SplitterService;
80pub use stream_cache::StreamCacheService;
81pub use streaming_split_segment::StreamingSplitSegment;
82pub use streaming_splitter::StreamingSplitterService;
83pub use throttler::{ThrottleSegment, ThrottlerService};
84pub use wire_tap::{WireTapConfig, WireTapLayer, WireTapService};