camel_processor/
lib.rs

1pub mod aggregator;
2mod archive_splitter;
3pub mod cache_eip;
4pub mod choice;
5pub mod circuit_breaker;
6pub mod claim_check;
7pub mod content_enricher;
8pub mod content_negotiation;
9pub mod convert_body;
10pub mod data_format;
11pub mod delayer;
12pub mod do_try;
13pub mod do_try_segment;
14pub mod dynamic_router;
15pub mod dynamic_set_header;
16pub mod dynamic_set_property;
17pub mod endpoint_pipeline;
18pub mod enrichment_strategy;
19pub mod error_handler;
20pub mod filter;
21pub mod idempotent_consumer;
22pub mod intercept_compose;
23pub mod json_schema_validate;
24pub mod load_balancer;
25pub mod log;
26pub mod loop_eip;
27pub mod map_body;
28pub mod marshal;
29pub mod multicast;
30pub mod multicast_segment;
31pub mod recipient_list;
32pub mod remove_header;
33pub mod resequencer;
34pub mod routing_slip;
35pub mod sampling;
36pub mod script_mutator;
37pub mod security_policy_layer;
38pub mod set_body;
39pub mod set_header;
40pub mod set_property;
41pub mod sort;
42pub mod split_segment;
43pub mod splitter;
44pub mod stream_cache;
45pub mod stream_codec;
46pub mod streaming_split_segment;
47pub mod streaming_splitter;
48pub mod tar_splitter;
49#[cfg(test)]
50mod test_log_capture;
51pub mod throttler;
52pub mod validate;
53pub mod wire_tap;
54pub mod zip_splitter;
55
56pub use aggregator::AggregatorService;
57pub use cache_eip::{
58    CAMEL_CACHE_INVALIDATED_COUNT, CAMEL_CACHE_PEEK_HIT, CAMEL_CACHE_PEEK_STALE, CacheClearService,
59    CacheInvalidateService, CacheInvalidateTarget, CachePeekStaleService, CacheService,
60    CacheStatsService, PeekStaleMissPolicy,
61};
62pub use choice::{ChoiceSegment, ChoiceService, WhenClause, WhenClauseSegment};
63pub use circuit_breaker::{
64    CircuitBreakerDecision, CircuitBreakerGate, CircuitBreakerLayer, CircuitBreakerService,
65};
66pub use claim_check::{ClaimCheckOp, ClaimCheckService, KeyExpression};
67pub use content_enricher::{EnrichService, PollEnrichService};
68pub use content_negotiation::{ContentNegotiationCheck, ContentNegotiationProcessor};
69pub use convert_body::ConvertBodyTo;
70pub use data_format::{
71    CAMEL_CSV_HEADER_RECORD, CsvConfig, CsvDataFormat, GzipConfig, GzipDataFormat, JsonConfig,
72    JsonDataFormat, QuoteMode, RecordSeparator, TarConfig, TarDataFormat, TarGzConfig,
73    TarGzDataFormat, XmlConfig, XmlDataFormat, ZipConfig, ZipDataFormat, builtin_data_format,
74    builtin_data_format_with_config,
75};
76pub use delayer::DelayerService;
77pub use do_try::{CatchClause, CatchMatcher, DoTryService};
78pub use do_try_segment::{CatchClauseSegment, DoTrySegment, FinallyClauseSegment};
79pub use dynamic_router::DynamicRouterService;
80pub use dynamic_set_header::{DynamicSetHeader, DynamicSetHeaderIfAbsent, DynamicSetHeaderLayer};
81pub use dynamic_set_property::{DynamicSetProperty, DynamicSetPropertyLayer};
82pub use endpoint_pipeline::EndpointPipelineService;
83pub use enrichment_strategy::{EnrichmentStrategy, ThrowOnNoPoll, UseEnrichedBody};
84#[rustfmt::skip]
85#[allow(deprecated)]
86pub use error_handler::{
87    DefaultRouteErrorHandler, ErrorHandlerLayer, ErrorHandlerService, RouteErrorHandler,
88    invoke_processor,
89};
90pub use filter::{FilterSegment, FilterService};
91pub use idempotent_consumer::{IdempotentConsumerSegment, MessageIdExpression};
92pub use intercept_compose::compose_divert;
93pub use json_schema_validate::JsonSchemaValidateService;
94pub use load_balancer::{LoadBalanceSegment, LoadBalancerService};
95pub use log::{LogLevel, LogProcessor};
96pub use loop_eip::{CAMEL_LOOP_INDEX, CAMEL_LOOP_SIZE, LoopSegment, LoopService};
97pub use map_body::{MapBody, MapBodyLayer};
98pub use marshal::{MarshalService, UnmarshalService};
99pub use multicast::{CAMEL_MULTICAST_COMPLETE, CAMEL_MULTICAST_INDEX, MulticastService};
100pub use multicast_segment::MulticastSegment;
101pub use recipient_list::RecipientListService;
102pub use remove_header::{RemoveHeader, RemoveHeaderLayer};
103pub use routing_slip::RoutingSlipService;
104pub use sampling::SamplingService;
105pub use script_mutator::ScriptMutator;
106pub use security_policy_layer::{SecurityPolicyLayer, SecurityPolicyService};
107pub use set_body::{SetBody, SetBodyLayer};
108pub use set_header::{SetHeader, SetHeaderIfAbsent, SetHeaderLayer};
109pub use set_property::{SetProperty, SetPropertyLayer};
110pub use sort::{SortExpression, SortKey, SortService};
111pub use split_segment::SplitSegment;
112pub use splitter::SplitterService;
113pub use stream_cache::StreamCacheService;
114pub use streaming_split_segment::StreamingSplitSegment;
115pub use streaming_splitter::StreamingSplitterService;
116pub use throttler::{ThrottleSegment, ThrottlerService};
117pub use validate::ValidateService;
118pub use wire_tap::{WireTapConfig, WireTapLayer, WireTapLifecycle, WireTapService};
119
120// Resequencer
121pub use resequencer::batch::BatchPolicy;
122pub use resequencer::stream::StreamPolicy;
123pub use resequencer::{PassthroughPolicy, ResequencePolicy, ResequencerConfig, ResequencerService};
camel_processor/lib.rs

camel_processor/
lib.rs
