Skip to main content

Crate camel_processor

Crate camel_processor 

Source

Re-exports§

pub use aggregator::AggregatorService;
pub use choice::ChoiceSegment;
pub use choice::ChoiceService;
pub use choice::WhenClause;
pub use choice::WhenClauseSegment;
pub use circuit_breaker::CircuitBreakerDecision;
pub use circuit_breaker::CircuitBreakerGate;
pub use circuit_breaker::CircuitBreakerLayer;
pub use circuit_breaker::CircuitBreakerService;
pub use claim_check::ClaimCheckOp;
pub use claim_check::ClaimCheckService;
pub use claim_check::KeyExpression;
pub use content_enricher::EnrichService;
pub use content_enricher::PollEnrichService;
pub use convert_body::ConvertBodyTo;
pub use data_format::JsonDataFormat;
pub use data_format::XmlDataFormat;
pub use data_format::ZipDataFormat;
pub use data_format::builtin_data_format;
pub use delayer::DelayerService;
pub use do_try::CatchClause;
pub use do_try::CatchMatcher;
pub use do_try::DoTryService;
pub use do_try_segment::CatchClauseSegment;
pub use do_try_segment::DoTrySegment;
pub use do_try_segment::FinallyClauseSegment;
pub use dynamic_router::DynamicRouterService;
pub use dynamic_set_header::DynamicSetHeader;
pub use dynamic_set_header::DynamicSetHeaderLayer;
pub use dynamic_set_property::DynamicSetProperty;
pub use dynamic_set_property::DynamicSetPropertyLayer;
pub use endpoint_pipeline::EndpointPipelineService;
pub use enrichment_strategy::EnrichmentStrategy;
pub use enrichment_strategy::ThrowOnNoPoll;
pub use enrichment_strategy::UseEnrichedBody;
pub use error_handler::DefaultRouteErrorHandler;
pub use error_handler::ErrorHandlerLayer;
pub use error_handler::ErrorHandlerService;
pub use error_handler::RouteErrorHandler;
pub use error_handler::invoke_processor;
pub use filter::FilterSegment;
pub use filter::FilterService;
pub use idempotent_consumer::IdempotentConsumerSegment;
pub use idempotent_consumer::MessageIdExpression;
pub use load_balancer::LoadBalanceSegment;
pub use load_balancer::LoadBalancerService;
pub use log::LogLevel;
pub use log::LogProcessor;
pub use loop_eip::CAMEL_LOOP_INDEX;
pub use loop_eip::CAMEL_LOOP_SIZE;
pub use loop_eip::LoopSegment;
pub use loop_eip::LoopService;
pub use map_body::MapBody;
pub use map_body::MapBodyLayer;
pub use marshal::MarshalService;
pub use marshal::UnmarshalService;
pub use multicast::CAMEL_MULTICAST_COMPLETE;
pub use multicast::CAMEL_MULTICAST_INDEX;
pub use multicast::MulticastService;
pub use multicast_segment::MulticastSegment;
pub use recipient_list::RecipientListService;
pub use routing_slip::RoutingSlipService;
pub use sampling::SamplingService;
pub use script_mutator::ScriptMutator;
pub use security_policy_layer::SecurityPolicyLayer;
pub use security_policy_layer::SecurityPolicyService;
pub use set_body::SetBody;
pub use set_body::SetBodyLayer;
pub use set_header::SetHeader;
pub use set_header::SetHeaderLayer;
pub use set_property::SetProperty;
pub use set_property::SetPropertyLayer;
pub use sort::SortExpression;
pub use sort::SortKey;
pub use sort::SortService;
pub use split_segment::SplitSegment;
pub use splitter::SplitterService;
pub use stream_cache::StreamCacheService;
pub use streaming_split_segment::StreamingSplitSegment;
pub use streaming_splitter::StreamingSplitterService;
pub use throttler::ThrottleSegment;
pub use throttler::ThrottlerService;
pub use validate::ValidateService;
pub use wire_tap::WireTapConfig;
pub use wire_tap::WireTapLayer;
pub use wire_tap::WireTapService;
pub use resequencer::batch::BatchPolicy;
pub use resequencer::stream::StreamPolicy;
pub use resequencer::PassthroughPolicy;
pub use resequencer::ResequencePolicy;
pub use resequencer::ResequencerConfig;
pub use resequencer::ResequencerService;

Modules§

aggregator
choice
circuit_breaker
claim_check
Claim Check EIP processor.
content_enricher
convert_body
data_format
delayer
do_try
Stop semantics (ADR-0025)
do_try_segment
Stop semantics (ADR-0025)
dynamic_router
dynamic_set_header
dynamic_set_property
endpoint_pipeline
enrichment_strategy
error_handler
filter
idempotent_consumer
Idempotent Consumer EIP — outcome-aware Segment implementation.
load_balancer
log
loop_eip
map_body
marshal
multicast
Stop semantics (ADR-0025)
multicast_segment
Stop semantics (ADR-0025)
recipient_list
resequencer
Resequencer — continuation-boundary EIP.
routing_slip
sampling
script_mutator
security_policy_layer
set_body
set_header
set_property
sort
split_segment
Stop semantics (ADR-0025)
splitter
stream_cache
stream_codec
streaming_split_segment
Stop semantics (ADR-0025)
streaming_splitter
throttler
validate
wire_tap
zip_splitter