org.springframework.integration.aggregator

Class AggregatingMessageHandler

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.handler.AbstractMessageHandler

org.springframework.integration.handler.AbstractMessageProducingHandler

org.springframework.integration.aggregator.AbstractCorrelatingMessageHandler

org.springframework.integration.aggregator.AggregatingMessageHandler

All Implemented Interfaces:

Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, ApplicationEventPublisherAware, Ordered, Orderable, MessageProducer, IntegrationEvaluationContextAware, TrackableComponent, NamedComponent, MessageHandler

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

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.integration.aggregator.AbstractCorrelatingMessageHandler

AbstractCorrelatingMessageHandler.SequenceAwareMessageGroup

Field Summary

Fields inherited from class org.springframework.integration.aggregator.AbstractCorrelatingMessageHandler

DEFAULT_SEND_TIMEOUT, messageStore

Fields inherited from class org.springframework.integration.handler.AbstractMessageProducingHandler

messagingTemplate

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor and Description
AggregatingMessageHandler(MessageGroupProcessor processor)
AggregatingMessageHandler(MessageGroupProcessor processor, MessageGroupStore store)
AggregatingMessageHandler(MessageGroupProcessor processor, MessageGroupStore store, CorrelationStrategy correlationStrategy, ReleaseStrategy releaseStrategy)

Method Summary

Modifier and Type	Method and Description
protected void	afterRelease(MessageGroup messageGroup, Collection<Message<?>> completedMessages) Allows you to provide additional logic that needs to be performed after the MessageGroup was released.
void	setExpireGroupsUponCompletion(boolean expireGroupsUponCompletion) Will set the 'expireGroupsUponCompletion' flag.

Methods inherited from class org.springframework.integration.aggregator.AbstractCorrelatingMessageHandler

afterRelease, completeGroup, completeGroup, destroy, expireGroup, findLastReleasedSequenceNumber, forceComplete, getComponentType, getCorrelationStrategy, getDiscardChannel, getDiscardChannelName, getEvaluationContext, getExpireGroupScheduledFutures, getGroupTimeoutExpression, getLockRegistry, getMessageStore, getMinimumTimeoutForEmptyGroups, getOutputProcessor, getReleaseStrategy, handleMessageInternal, isLockRegistrySet, isReleasePartialSequences, isSendPartialResultOnExpiry, isSequenceAware, obtainGroupTimeout, onInit, setApplicationEventPublisher, setCorrelationStrategy, setDiscardChannel, setDiscardChannelName, setExpireGroupsUponTimeout, setForceReleaseAdviceChain, setGroupTimeoutExpression, setIntegrationEvaluationContext, setLockRegistry, setMessageStore, setMinimumTimeoutForEmptyGroups, setReleasePartialSequences, setReleaseStrategy, setSendPartialResultOnExpiry, setTaskScheduler, store, verifyResultCollectionConsistsOfMessages

Methods inherited from class org.springframework.integration.handler.AbstractMessageProducingHandler

getOutputChannel, produceOutput, sendOutputs, setChannelResolver, setOutputChannel, setOutputChannelName, setSendTimeout, shouldCopyRequestHeaders, shouldSplitOutput

Methods inherited from class org.springframework.integration.handler.AbstractMessageHandler

getOrder, handleMessage, setOrder, setShouldTrack

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setMessageBuilderFactory, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.springframework.integration.support.context.NamedComponent

getComponentName

Constructor Detail

AggregatingMessageHandler

public AggregatingMessageHandler(MessageGroupProcessor processor,
                                 MessageGroupStore store,
                                 CorrelationStrategy correlationStrategy,
                                 ReleaseStrategy releaseStrategy)

AggregatingMessageHandler

public AggregatingMessageHandler(MessageGroupProcessor processor,
                                 MessageGroupStore store)

AggregatingMessageHandler

public AggregatingMessageHandler(MessageGroupProcessor processor)

Method Detail

setExpireGroupsUponCompletion

public void setExpireGroupsUponCompletion(boolean expireGroupsUponCompletion)

Will set the 'expireGroupsUponCompletion' flag.

Parameters:

expireGroupsUponCompletion - true when groups should be expired on completion.

See Also:

afterRelease(org.springframework.integration.store.MessageGroup, java.util.Collection<org.springframework.messaging.Message<?>>)

afterRelease

protected void afterRelease(MessageGroup messageGroup,
                            Collection<Message<?>> completedMessages)

Description copied from class: AbstractCorrelatingMessageHandler

Allows you to provide additional logic that needs to be performed after the MessageGroup was released.

Specified by:

afterRelease in class AbstractCorrelatingMessageHandler

Parameters:

messageGroup - The group.

completedMessages - The completed messages.