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