Uses of Interface
org.springframework.integration.aggregator.MessageGroupProcessor
Package
Description
Provides classes related to message aggregation.
Root package of the Spring Integration Java DSL.
Provides support classes for file-based aggregation logic.
-
Uses of MessageGroupProcessor in org.springframework.integration.aggregator
Modifier and TypeClassDescriptionclass
Base class for MessageGroupProcessor implementations that aggregate the group of Messages into a single Message.class
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.class
TheMessageGroupProcessor
implementation with delegation to the provideddelegate
and optional aggregation for headers.class
AMessageGroupProcessor
implementation that evaluates a SpEL expression.class
MessageGroupProcessor that serves as an adapter for the invocation of a POJO method.class
This class implements all the strategy interfaces needed for a default resequencer.class
AMessageGroupProcessor
that simply returns the messages in the group.Modifier and TypeMethodDescriptionAbstractCorrelatingMessageHandler.getOutputProcessor()
Return a configuredMessageGroupProcessor
.Modifier and TypeMethodDescriptionvoid
AbstractCorrelatingMessageHandler.setOutputProcessor
(MessageGroupProcessor outputProcessor) Specify aMessageGroupProcessor
for the output function.ModifierConstructorDescriptionAbstractCorrelatingMessageHandler
(MessageGroupProcessor processor, MessageGroupStore store) AbstractCorrelatingMessageHandler
(MessageGroupProcessor processor, MessageGroupStore store, CorrelationStrategy correlationStrategy, ReleaseStrategy releaseStrategy) AggregatingMessageHandler
(MessageGroupProcessor processor) AggregatingMessageHandler
(MessageGroupProcessor processor, MessageGroupStore store) AggregatingMessageHandler
(MessageGroupProcessor processor, MessageGroupStore store, CorrelationStrategy correlationStrategy, ReleaseStrategy releaseStrategy) BarrierMessageHandler
(long requestTimeout, long triggerTimeout, MessageGroupProcessor outputProcessor) Construct an instance with the provided timeout and output processor, and default correlation strategy.BarrierMessageHandler
(long requestTimeout, long triggerTimeout, MessageGroupProcessor outputProcessor, CorrelationStrategy correlationStrategy) Construct an instance with the provided timeout and output processor, and default correlation strategy.BarrierMessageHandler
(long timeout, MessageGroupProcessor outputProcessor) Construct an instance with the provided timeout and output processor, and default correlation strategy.BarrierMessageHandler
(long timeout, MessageGroupProcessor outputProcessor, CorrelationStrategy correlationStrategy) Construct an instance with the provided timeout and output processor, and default correlation strategy.DelegatingMessageGroupProcessor
(MessageGroupProcessor delegate, Function<MessageGroup, Map<String, Object>> headersFunction) ResequencingMessageHandler
(MessageGroupProcessor processor) ResequencingMessageHandler
(MessageGroupProcessor processor, MessageGroupStore store) ResequencingMessageHandler
(MessageGroupProcessor processor, MessageGroupStore store, CorrelationStrategy correlationStrategy, ReleaseStrategy releaseStrategy) -
Uses of MessageGroupProcessor in org.springframework.integration.dsl
Modifier and TypeMethodDescriptionAggregatorSpec.outputProcessor
(MessageGroupProcessor outputProcessor) A processor to determine the output message from the released group.BarrierSpec.outputProcessor
(MessageGroupProcessor outputProcessor) -
Uses of MessageGroupProcessor in org.springframework.integration.file.aggregator
Modifier and TypeClassDescriptionclass
AnAbstractAggregatingMessageGroupProcessor
implementation for file content collecting previously splitted by theFileSplitter
with themarkers
option turned on.class
A convenient component to utilize aFileSplitter.FileMarker
-based aggregation logic.