Name | Description | Type | Package | Framework |
SimpleMessageGroupProcessor | A MessageGroupProcessor that simply returns the messages in the group. | Class | org.springframework.integration.aggregator | Spring Integration |
SequenceNumberComparator | Class | org.springframework.integration.aggregator | Spring Integration | |
SequenceSizeReleaseStrategy | An implementation of ReleaseStrategy that simply compares the current size of the message list to theexpected 'sequenceSize'. | Class | org.springframework.integration.aggregator | Spring Integration |
ResequencingMessageHandler | Resequencer specific implementation of AbstractCorrelatingMessageHandler. | Class | org.springframework.integration.aggregator | Spring Integration |
ResequencingMessageGroupProcessor | This class implements all the strategy interfaces needed for a default resequencer. | Class | org.springframework.integration.aggregator | Spring Integration |
ReleaseStrategy | Strategy for determining when a group of messages reaches a state ofcompletion (i. | Interface | org.springframework.integration.aggregator | Spring Integration |
PassThroughMessageGroupProcessor | This implementation of MessageGroupProcessor will return all messages inside the group. | Class | org.springframework.integration.aggregator | Spring Integration |
MethodInvokingReleaseStrategy | A ReleaseStrategy that invokes a method on a plain old Java object. | Class | org.springframework.integration.aggregator | Spring Integration |
MethodInvokingMessageListProcessor | A MessageListProcessor implementation that invokes a method on a target POJO. | Class | org.springframework.integration.aggregator | Spring Integration |
MethodInvokingMessageGroupProcessor | MessageGroupProcessor that serves as an adapter for the invocation of a POJO method. | Class | org.springframework.integration.aggregator | Spring Integration |
MethodInvokingCorrelationStrategy | CorrelationStrategy implementation that works as an adapter to another bean. | Class | org.springframework.integration.aggregator | Spring Integration |
MessageSequenceComparator | A Comparator implementation based on the 'sequence number'property of a Message's header. | Class | org.springframework.integration.aggregator | Spring Integration |
MessageListProcessor | Interface | org.springframework.integration.aggregator | Spring Integration | |
MessageGroupProcessor | A processor for correlated groups of messages. | Interface | org.springframework.integration.aggregator | Spring Integration |
MessageGroupExpiredEvent | Event representing the expiration of a message group. | Class | org.springframework.integration.aggregator | Spring Integration |
MessageCountReleaseStrategy | A ReleaseStrategy that releases only the first n messages, where n is a threshold. | Class | org.springframework.integration.aggregator | Spring Integration |
HeaderAttributeCorrelationStrategy | Default implementation of CorrelationStrategy. | Class | org.springframework.integration.aggregator | Spring Integration |
ExpressionEvaluatingReleaseStrategy | A ReleaseStrategy that evaluates an expression. | Class | org.springframework.integration.aggregator | Spring Integration |
ExpressionEvaluatingMessageListProcessor | A base class for aggregators that evaluates a SpEL expression with the message list as the root object within theSince:2. | Class | org.springframework.integration.aggregator | Spring Integration |
ExpressionEvaluatingMessageGroupProcessor | A MessageGroupProcessor implementation that evaluates a SpEL expression. | Class | org.springframework.integration.aggregator | Spring Integration |
ExpressionEvaluatingCorrelationStrategy | CorrelationStrategy implementation that evaluates an expression. | Class | org.springframework.integration.aggregator | Spring Integration |
DefaultAggregatingMessageGroupProcessor | This implementation of MessageGroupProcessor will take the messages from theMessageGroup and pass them on in a single message with a Collection as a payload. | Class | org.springframework.integration.aggregator | Spring Integration |
CorrelationStrategy | Strategy for determining how messages can be correlated. | Interface | org.springframework.integration.aggregator | Spring Integration |
CorrelatingMessageBarrier | This Endpoint serves as a barrier for messages that should not be processed yet. | Class | org.springframework.integration.aggregator | Spring Integration |
BarrierMessageHandler | A message handler that suspends the thread until a message with correspondingcorrelation is passed into the trigger method or | Class | org.springframework.integration.aggregator | Spring Integration |
AggregatingMessageHandler | Aggregator specific implementation of AbstractCorrelatingMessageHandler. | Class | org.springframework.integration.aggregator | Spring Integration |
AbstractCorrelatingMessageHandler .SequenceAwareMessageGroup | Class | org.springframework.integration.aggregator.AbstractCorrelatingMessageHandler | Spring Integration | |
AbstractCorrelatingMessageHandler | Abstract Message handler that holds a buffer of correlated messages in aMessageStore. | Class | org.springframework.integration.aggregator | Spring Integration |
AbstractAggregatingMessageGroupProcessor | Base class for MessageGroupProcessor implementations that aggregate the group of Messages into a single Message. | Class | org.springframework.integration.aggregator | Spring Integration |
TimeoutCountSequenceSizeReleaseStrategy | A ReleaseStrategy that releases all messages if any of the following is true:The sequence is complete (if there is one). | Class | org.springframework.integration.aggregator | Spring Integration |