Package | Description |
---|---|
org.apache.camel.builder | |
org.apache.camel.component.dataset |
A DataSet Endpoint for testing of endpoints using defined DataSets
|
org.apache.camel.component.directvm |
The Direct VM Component which synchronously invokes
the consumer when a producer sends an exchange to the endpoint.
|
org.apache.camel.component.seda | |
org.apache.camel.management |
Camel management
|
org.apache.camel.management.mbean |
Camel management JMX MBeans
|
org.apache.camel.model |
The JAXB POJOs for the
XML Configuration
of the routing rules.
|
org.apache.camel.processor |
A collection of Processor
implementations which are used to implement the
Enterprise Integration Patterns
|
org.apache.camel.processor.interceptor |
Helper classes for interceptors.
|
Class and Description |
---|
ErrorHandler
An interface used to represent an error handler
|
RedeliveryPolicy
The policy used to decide how many times to redeliver and the time between
the redeliveries before being sent to a Dead Letter
Channel
|
Class and Description |
---|
ThroughputLogger
A logger for logging message throughput.
|
Class and Description |
---|
DelegateAsyncProcessor
A Delegate pattern which delegates processing to a nested
AsyncProcessor which can
be useful for implementation inheritance when writing an Policy
Important: This implementation does support the asynchronous routing engine. |
Class and Description |
---|
MulticastProcessor
Implements the Multicast pattern to send a message exchange to a number of
endpoints, each endpoint receiving a copy of the message exchange.
|
Class and Description |
---|
DelegateAsyncProcessor
A Delegate pattern which delegates processing to a nested
AsyncProcessor which can
be useful for implementation inheritance when writing an Policy
Important: This implementation does support the asynchronous routing engine. |
Class and Description |
---|
ChoiceProcessor
Implements a Choice structure where one or more predicates are used which if
they are true their processors are used, with a default otherwise clause used
if none match.
|
ConvertBodyProcessor
A processor which converts the payload of the input message to be of the given type
If the conversion fails an
InvalidPayloadException is thrown. |
Delayer
A Delayer which
delays processing the exchange until the correct amount of time has elapsed
using an expression to determine the delivery time.
|
DynamicRouter
Implements a Dynamic Router pattern
where the destination(s) is computed at runtime.
|
Enricher
A content enricher that enriches input data by first obtaining additional
data from a resource represented by an endpoint
producer
and second by aggregating input data and additional data. |
ExchangePatternProcessor
Processor to set
ExchangePattern on the Exchange . |
FilterProcessor
The processor which implements the
Message Filter EIP pattern.
|
LogProcessor
A processor which evaluates an
Expression and logs it. |
LoopProcessor
The processor which sends messages in a loop.
|
MarshalProcessor
Marshals the body of the incoming message using the given
data format
|
MulticastProcessor
Implements the Multicast pattern to send a message exchange to a number of
endpoints, each endpoint receiving a copy of the message exchange.
|
PollEnricher
A content enricher that enriches input data by first obtaining additional
data from a resource represented by an endpoint
producer
and second by aggregating input data and additional data. |
RecipientList
Implements a dynamic Recipient List
pattern where the list of actual endpoints to send a message exchange to are
dependent on some dynamic expression.
|
RemoveHeaderProcessor
A processor which removes the header from the IN or OUT message
|
RemoveHeadersProcessor
A processor which removes one ore more headers from the IN or OUT message
|
RemovePropertiesProcessor
A processor which removes one ore more properties from the exchange
|
RemovePropertyProcessor
A processor which removes the property from the exchange
|
Resequencer
An implementation of the Resequencer
which can reorder messages within a batch.
|
RollbackProcessor
Processor for marking an
Exchange to rollback. |
RoutingSlip
Implements a Routing Slip
pattern where the list of actual endpoints to send a message exchange to are
dependent on the value of a message header.
|
SamplingThrottler
A
SamplingThrottler is a special kind of throttler. |
ScriptProcessor
A processor which executes the script as an expression and does not change the message body.
|
SendDynamicProcessor
Processor for forwarding exchanges to a dynamic endpoint destination.
|
SendProcessor
Processor for forwarding exchanges to a static endpoint destination.
|
SetBodyProcessor
A processor which sets the body on the IN or OUT message with an
Expression |
SetHeaderProcessor
A processor which sets the header on the IN or OUT message with an
Expression |
SetPropertyProcessor
A processor which sets the property on the exchange with an
Expression |
Splitter
Implements a dynamic Splitter pattern
where an expression is evaluated to iterate through each of the parts of a
message and then each part is then send to some endpoint.
|
StopProcessor
Stops continue processing the route and marks it as complete.
|
StreamResequencer
A resequencer that re-orders a (continuous) stream of
Exchange s. |
ThreadsProcessor
Threads processor that leverage a thread pool for continue processing the
Exchange s
using the asynchronous routing engine. |
Throttler
A Throttler
will set a limit on the maximum number of message exchanges which can be sent
to a processor within a specific time period.
|
ThroughputLogger
A logger for logging message throughput.
|
ThrowExceptionProcessor |
TransformProcessor
A processor which sets the body on the OUT message with an
Expression . |
UnmarshalProcessor
Unmarshals the body of the incoming message using the given
data format
|
WireTapProcessor
Processor for wire tapping exchanges to an endpoint destination.
|
Class and Description |
---|
CatchProcessor
A processor which catches exceptions.
|
FilterProcessor
The processor which implements the
Message Filter EIP pattern.
|
RedeliveryPolicy
The policy used to decide how many times to redeliver and the time between
the redeliveries before being sent to a Dead Letter
Channel
|
Resequencer
An implementation of the Resequencer
which can reorder messages within a batch.
|
StreamResequencer
A resequencer that re-orders a (continuous) stream of
Exchange s. |
Class and Description |
---|
BatchProcessor
Deprecated.
may be removed in the future when we overhaul the resequencer EIP
|
CamelInternalProcessor.UnitOfWorkProcessorAdvice
Advice to inject new
UnitOfWork to the Exchange if needed, and as well to ensure
the UnitOfWork is done and stopped. |
CamelInternalProcessorAdvice
An advice (before and after) to execute cross cutting functionality in the Camel routing engine.
|
DefaultErrorHandler
Default error handler
|
DefaultExchangeFormatter.OutputStyle |
DelayProcessorSupport
A useful base class for any processor which provides some kind of throttling
or delayed processing.
|
DelegateAsyncProcessor
A Delegate pattern which delegates processing to a nested
AsyncProcessor which can
be useful for implementation inheritance when writing an Policy
Important: This implementation does support the asynchronous routing engine. |
ErrorHandler
An interface used to represent an error handler
|
ErrorHandlerSupport
Support class for
ErrorHandler implementations. |
FilterProcessor
The processor which implements the
Message Filter EIP pattern.
|
MulticastProcessor
Implements the Multicast pattern to send a message exchange to a number of
endpoints, each endpoint receiving a copy of the message exchange.
|
ProcessorExchangePair
Exchange pair to be executed by
MulticastProcessor . |
RedeliveryErrorHandler
Base redeliverable error handler that also supports a final dead letter queue in case
all redelivery attempts fail.
|
RedeliveryErrorHandler.RedeliveryData
Contains the current redelivery data
|
RedeliveryPolicy
The policy used to decide how many times to redeliver and the time between
the redeliveries before being sent to a Dead Letter
Channel
|
RoutingSlip
Implements a Routing Slip
pattern where the list of actual endpoints to send a message exchange to are
dependent on the value of a message header.
|
RoutingSlip.RoutingSlipIterator
The iterator to be used for retrieving the next routing slip(s) to be used.
|
SendDynamicProcessor
Processor for forwarding exchanges to a dynamic endpoint destination.
|
TryProcessor
Implements try/catch/finally type processing
|
Class and Description |
---|
CamelInternalProcessor
Internal
Processor that Camel routing engine used during routing for cross cutting functionality such as:
Execute UnitOfWork
Keeping track which route currently is being routed
Execute RoutePolicy
Gather JMX performance statics
Tracing
Debugging
Message History
Stream Caching
... |
CamelLogProcessor
A
Processor which just logs to a CamelLogger object which can be used
as an exception handler instead of using a dead letter queue. |
DelayProcessorSupport
A useful base class for any processor which provides some kind of throttling
or delayed processing.
|
DelegateAsyncProcessor
A Delegate pattern which delegates processing to a nested
AsyncProcessor which can
be useful for implementation inheritance when writing an Policy
Important: This implementation does support the asynchronous routing engine. |
Apache Camel