Package org.springframework.integration.aggregator

@NullMarked package org.springframework.integration.aggregator

Provides classes related to message aggregation.

Related Packages

Package	Description
org.springframework.integration	Base package for Spring Integration Core.

Class	Description
AbstractAggregatingMessageGroupProcessor	Base class for MessageGroupProcessor implementations that aggregate the group of Messages into a single Message.
AbstractCorrelatingMessageHandler	Abstract Message handler that holds a buffer of correlated messages in a MessageStore.
AbstractCorrelatingMessageHandler.SequenceAwareMessageGroup
AggregatingMessageHandler	Aggregator specific implementation of AbstractCorrelatingMessageHandler.
BarrierMessageHandler	A message handler that suspends the thread until a message with corresponding correlation is passed into the trigger method or the timeout occurs.
CorrelatingMessageBarrier	This Endpoint serves as a barrier for messages that should not be processed yet.
CorrelationStrategy	Strategy for determining how messages can be correlated.
DefaultAggregateHeadersFunction	The Function implementation for a default headers merging in the aggregator component.
DefaultAggregatingMessageGroupProcessor	This implementation of MessageGroupProcessor will take the messages from the MessageGroup and pass them on in a single message with a Collection as a payload.
DelegatingMessageGroupProcessor	The MessageGroupProcessor implementation with delegation to the provided delegate and optional aggregation for headers.
ExpressionEvaluatingCorrelationStrategy	CorrelationStrategy implementation that evaluates an expression.
ExpressionEvaluatingMessageGroupProcessor	A MessageGroupProcessor implementation that evaluates a SpEL expression.
ExpressionEvaluatingMessageListProcessor	A base class for aggregators that evaluates a SpEL expression with the message list as the root object within the evaluation context.
ExpressionEvaluatingReleaseStrategy	A ReleaseStrategy that evaluates an expression.
FluxAggregatorMessageHandler	The AbstractMessageProducingHandler implementation for aggregation logic based on Reactor's Flux.groupBy(java.util.function.Function<? super T, ? extends K>) and Flux.window(int) operators.
GroupConditionProvider	A contract which can be implemented on the ReleaseStrategy and used in the AbstractCorrelatingMessageHandler to populate the provided group condition supplier.
HeaderAttributeCorrelationStrategy	Default implementation of CorrelationStrategy.
MessageCountReleaseStrategy	A ReleaseStrategy that releases only the first n messages, where n is a threshold.
MessageGroupExpiredEvent	Event representing the expiration of a message group.
MessageGroupProcessor	A processor for correlated groups of messages.
MessageListProcessor
MessageSequenceComparator
MethodInvokingCorrelationStrategy	CorrelationStrategy implementation that works as an adapter to another bean.
MethodInvokingMessageGroupProcessor	MessageGroupProcessor that serves as an adapter for the invocation of a POJO method.
MethodInvokingMessageListProcessor<T>	A MessageListProcessor implementation that invokes a method on a target POJO.
MethodInvokingReleaseStrategy	A ReleaseStrategy that invokes a method on a plain old Java object.
ReleaseStrategy	Strategy for determining when a group of messages reaches a state of completion (i.e.
ResequencingMessageGroupProcessor	This class implements all the strategy interfaces needed for a default resequencer.
ResequencingMessageHandler	Resequencer specific implementation of AbstractCorrelatingMessageHandler.
SequenceSizeReleaseStrategy	An implementation of ReleaseStrategy that simply compares the current size of the message list to the expected 'sequenceSize'.
SimpleMessageGroupProcessor	A MessageGroupProcessor that simply returns the messages in the group.
SimpleSequenceSizeReleaseStrategy	An implementation of ReleaseStrategy that simply compares the current size of the message list to the expected 'sequenceSize'.
TimeoutCountSequenceSizeReleaseStrategy	A ReleaseStrategy that releases all messages if any of the following is true: The sequence is complete (if there is one). There are more messages than a threshold set by the user. The time elapsed since the earliest message, according to their timestamps, if present, exceeds a timeout set by the user.