|
|||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |
Interface Summary | |
---|---|
Aggregator | Strategy interface for aggregating a list of Messages into a
single Message . |
CompletionStrategy | Strategy for determining when a group of messages reaches a state of completion (i.e. |
MessageBarrier | Common interface for routing components that release a list of
Messages based upon a condition that is met when a
Message arrives. |
Class Summary | |
---|---|
AbstractMessageBarrier | Default implementation for a MessageBarrier . |
AbstractMessageBarrierHandler | Base class for MessageBarrier -based MessageHandlers. |
AggregatingMessageHandler | An AbstractMessageBarrierHandler that waits for a complete
group of Messages to arrive and then delegates to an
Aggregator to combine them into a single Message . |
AggregationBarrier | MessageBarrier implementation for message aggregation. |
AggregatorAdapter | Aggregator adapter for methods annotated with @Aggregator
and for 'aggregator ' elements that include a 'method ' attribute
(e.g. |
AggregatorMessageHandlerCreator | Creates an AggregatorAdapter for methods that aggregate messages. |
CompletionStrategyAdapter | Adapter for methods annotated with @CompletionStrategy
and for 'completion-strategy ' elements that include a 'method '
attribute (e.g. |
MessageSequenceComparator | A Comparator implementation based on the 'sequence number'
property of a Message's header. |
ResequencingMessageBarrier | MessageBarrier implementation for resequencing. |
ResequencingMessageHandler | An AbstractMessageBarrierHandler that waits for a group of
Messages to arrive and re-sends them in order, sorted
by their sequenceNumber . |
SequenceSizeCompletionStrategy | An implementation of CompletionStrategy that simply compares the
current size of the message list to the expected 'sequenceSize' according to
the first Message in the list. |
|
|||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |