|
|||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |
Interface Summary | |
---|---|
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 | |
---|---|
AbstractMessageAggregator | A base class for aggregating a group of Messages into a single Message. |
AbstractMessageBarrier | Default implementation for a MessageBarrier . |
AbstractMessageBarrierHandler | Base class for MessageBarrier -based Message Handlers. |
AggregationBarrier | MessageBarrier implementation for message aggregation. |
CompletionStrategyAdapter | Adapter for methods annotated with
@CompletionStrategy
and for 'completion-strategy ' elements that include a 'method '
attribute (e.g. |
MessageListMethodAdapter | Base class for implementing adapters for methods which take as an argument a
list of Message instances or payloads. |
MessageSequenceComparator | A Comparator implementation based on the 'sequence number'
property of a Message's header. |
MethodInvokingAggregator | AbstractMessageAggregator adapter for methods annotated with
@Aggregator annotation and for aggregator
elements (e.g. |
Resequencer | An AbstractMessageBarrierHandler that waits for a group of
Messages to arrive and re-sends them in order, sorted
by their sequenceNumber . |
ResequencingMessageBarrier | MessageBarrier implementation for resequencing. |
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 |