|
||||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |
See:
Description
Interface Summary | |
---|---|
ErrorHandler | An interface used to represent an error handler |
Traceable | Traceable processors allowing easeir tracing using constructed labels to help identify the processor and where its defined in the route model. |
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. |
AOPProcessor | |
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
If the convertions fails an InvalidPayloadException is thrown. |
DeadLetterChannel | Implements a Dead Letter
Channel after attempting to redeliver the message using the
RedeliveryPolicy |
DefaultChannel | DefaultChannel is the default Channel . |
DefaultErrorHandler | Default error handler |
Delayer | A Delayer which delays processing the exchange until the correct amount of time has elapsed using an expression to determine the delivery time. |
DelayProcessorSupport | A useful base class for any processor which provides some kind of throttling or delayed processing |
DelegateProcessor | A Delegate pattern which delegates processing to a nested processor which can
be useful for implementation inheritance when writing an Policy |
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. |
ErrorHandlerSupport | Support class for ErrorHandler implementations. |
ExchangePatternProcessor | |
FilterProcessor | The processor which implements the Message Filter EIP pattern. |
InterceptEndpointProcessor | Endpoint intercept processor so we know the processor is supposed to intercept an andpoint. |
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. |
OnCompletionProcessor | |
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 |
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. |
RedeliveryErrorHandler | Base redeliverable error handler that also suppors a final dead letter queue in case all redelivery attempts fail. |
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. |
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. |
SendProcessor | Processor for forwarding exchanges to an endpoint destination. |
SortProcessor | A processor that sorts the expression using a comparator |
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 processing exchanges. |
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 | The processor which implements the ThrowException 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 |
WireTapProcessor | Processor for wire tapping exchanges to an endpoint destination. |
A collection of Processor implementations which are used to implement the Enterprise Integration Patterns
|
||||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |