Class AggregatingMessageHandler

All Implemented Interfaces:
org.reactivestreams.Subscriber<Message<?>>, Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, ApplicationEventPublisherAware, Lifecycle, Ordered, ExpressionCapable, Orderable, MessageProducer, DiscardingMessageHandler, HeaderPropagationAware, IntegrationPattern, NamedComponent, IntegrationManagement, ManageableLifecycle, TrackableComponent, MessageHandler, reactor.core.CoreSubscriber<Message<?>>

public class AggregatingMessageHandler extends AbstractCorrelatingMessageHandler
Aggregator specific implementation of AbstractCorrelatingMessageHandler. Will remove MessageGroups in the afterRelease(org.springframework.integration.store.MessageGroup, java.util.Collection<org.springframework.messaging.Message<?>>) only if 'expireGroupsUponCompletion' flag is set to 'true'.
Since:
2.1
Author:
Oleg Zhurakousky, Artem Bilan, Gary Russell