camel_processor/
lib.rs

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

camel_processor/
lib.rs
