Package org.apache.camel.processor

A collection of Processor implementations which are used to implement the Enterprise Integration Patterns

See:
          Description

Interface Summary
ErrorHandler An interface used to represent an error handler
 

Class Summary
Aggregator An implementation of the Aggregator pattern where a batch of messages are processed (up to a maximum amount or until some timeout is reached) and messages for the same correlation key are combined together using some kind of AggregationStrategy (by default the latest message is used) to compress many message exchanges into a smaller number of exchanges.
BatchProcessor A base class for any kind of Processor which implements some kind of batch processing.
CatchProcessor A processor which catches exceptions.
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.
CompositeProcessor Represents a composite pattern, aggregating a collection of processors together as a single processor
ConvertBodyProcessor A processor which converts the payload of the input message to be of the given type
DeadLetterChannel Implements a Dead Letter Channel after attempting to redeliver the message using the RedeliveryPolicy
Delayer A Delayer which delays processing the exchange until the correct amount of time has elapsed using an expression to determine the delivery time.
DelayPolicy The base policy used when a fixed delay is needed.
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
DelegateProcessor A Delegate pattern which delegates processing to a nested processor which can be useful for implementation inheritance when writing an Policy
ErrorHandlerSupport Support class for ErrorHandler implementations.
ExchangePatternProcessor  
FilterProcessor The processor which implements the Message Filter EIP pattern.
HandleFaultProcessor  
Interceptor An interceptor which provides the processing logic as a pluggable processor which allows the DelegateProcessor.proceed(Exchange) method to be called at some point
Logger A Processor which just logs to a Log object which can be used as an exception handler instead of using a dead letter queue.
LoggingErrorHandler An ErrorHandler which uses commons-logging to dump the error
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.
Pipeline Creates a Pipeline pattern where the output of the previous step is sent as input to the next step, reusing the same message exchanges
ProceedProcessor A Processor which proceeds on an Interceptor
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.
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.
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.
SendProcessor Processor for forwarding exchanges to an endpoint destination.
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.
StreamResequencer A resequencer that re-orders a (continuous) stream of Exchanges.
ThreadProcessor A processor that forces async processing of the exchange using a thread pool.
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.
ThrowFaultProcessor The processor which implements the ThrowFault DSL
TransformProcessor A processor which sets the body on the OUT message with an expression
TryProcessor Implements try/catch/finally type processing
UnitOfWorkProcessor Handles calling the UnitOfWork.done() method when processing of an exchange is complete.
UnmarshalProcessor Unmarshals the body of the incoming message using the given data format
 

Package org.apache.camel.processor Description

A collection of Processor implementations which are used to implement the Enterprise Integration Patterns



Copyright © 2010 IONA Open Source Community. All Rights Reserved.