Uses of Interface
org.springframework.integration.aggregator.MessageGroupProcessor
Packages that use 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
Classes in org.springframework.integration.aggregator that implement MessageGroupProcessorModifier and TypeClassDescriptionclassBase class for MessageGroupProcessor implementations that aggregate the group of Messages into a single Message.classThis implementation of MessageGroupProcessor will take the messages from the MessageGroup and pass them on in a single message with a Collection as a payload.classTheMessageGroupProcessorimplementation with delegation to the provideddelegateand optional aggregation for headers.classAMessageGroupProcessorimplementation that evaluates a SpEL expression.classMessageGroupProcessor that serves as an adapter for the invocation of a POJO method.classThis class implements all the strategy interfaces needed for a default resequencer.classAMessageGroupProcessorthat simply returns the messages in the group.Methods in org.springframework.integration.aggregator that return MessageGroupProcessorModifier and TypeMethodDescriptionAbstractCorrelatingMessageHandler.getOutputProcessor()Return a configuredMessageGroupProcessor.Methods in org.springframework.integration.aggregator with parameters of type MessageGroupProcessorModifier and TypeMethodDescriptionvoidAbstractCorrelatingMessageHandler.setOutputProcessor(MessageGroupProcessor outputProcessor) Specify aMessageGroupProcessorfor the output function.Constructors in org.springframework.integration.aggregator with parameters of type MessageGroupProcessorModifierConstructorDescriptionAbstractCorrelatingMessageHandler(MessageGroupProcessor processor, MessageGroupStore store) AbstractCorrelatingMessageHandler(MessageGroupProcessor processor, MessageGroupStore store, @Nullable CorrelationStrategy correlationStrategy, @Nullable ReleaseStrategy releaseStrategy) AggregatingMessageHandler(MessageGroupProcessor processor) AggregatingMessageHandler(MessageGroupProcessor processor, MessageGroupStore store) AggregatingMessageHandler(MessageGroupProcessor processor, MessageGroupStore store, @Nullable CorrelationStrategy correlationStrategy, @Nullable 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, @Nullable 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
Methods in org.springframework.integration.dsl with parameters of type MessageGroupProcessorModifier 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
Classes in org.springframework.integration.file.aggregator that implement MessageGroupProcessorModifier and TypeClassDescriptionclassAnAbstractAggregatingMessageGroupProcessorimplementation for file content collecting previously splitted by theFileSplitterwith themarkersoption turned on.classA convenient component to utilize aFileSplitter.FileMarker-based aggregation logic.