org.springframework.integration.aggregator

Class ResequencingMessageHandler

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.ResequencingMessageHandler

All Implemented Interfaces:

Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, ApplicationEventPublisherAware, Ordered, Orderable, MessageProducer, NamedComponent, ConfigurableMetricsAware<AbstractMessageHandlerMetrics>, IntegrationManagement, IntegrationStatsManagement, MessageHandlerMetrics, TrackableComponent, MessageHandler

public class ResequencingMessageHandler
extends AbstractCorrelatingMessageHandler

Resequencer specific implementation of AbstractCorrelatingMessageHandler. Will remove MessageGroups only if 'sequenceSize' is provided and reached.

Since:

2.1

Author:

Oleg Zhurakousky, Gary Russell

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

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
ResequencingMessageHandler(MessageGroupProcessor processor)
ResequencingMessageHandler(MessageGroupProcessor processor, MessageGroupStore store)
ResequencingMessageHandler(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.
protected void	afterRelease(MessageGroup messageGroup, Collection<Message<?>> completedMessages, boolean timeout) Subclasses may override if special action is needed because the group was released or discarded due to a timeout.
void	setExpireGroupsUponTimeout(boolean expireGroupsUponTimeout) Expire (completely remove) a group if it is completed due to timeout.

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

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, setForceReleaseAdviceChain, setGroupTimeoutExpression, setIntegrationEvaluationContext, setLockRegistry, setMessageStore, setMinimumTimeoutForEmptyGroups, setReleasePartialSequences, setReleaseStrategy, setSendPartialResultOnExpiry, setTaskScheduler, store, verifyResultCollectionConsistsOfMessages

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

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

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

configureMetrics, getActiveCount, getActiveCountLong, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabled

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

afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, 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

ResequencingMessageHandler

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

ResequencingMessageHandler

public ResequencingMessageHandler(MessageGroupProcessor processor,
                                  MessageGroupStore store)

ResequencingMessageHandler

public ResequencingMessageHandler(MessageGroupProcessor processor)

Method Detail

setExpireGroupsUponTimeout

public void setExpireGroupsUponTimeout(boolean expireGroupsUponTimeout)

Expire (completely remove) a group if it is completed due to timeout. Default true (overridden to false for a resequencer so late messages are immediately discarded rather than waiting for the next timeout)

Overrides:

setExpireGroupsUponTimeout in class AbstractCorrelatingMessageHandler

Parameters:

expireGroupsUponTimeout - the expireGroupsUponTimeout to set

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.

afterRelease

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

Description copied from class: AbstractCorrelatingMessageHandler

Subclasses may override if special action is needed because the group was released or discarded due to a timeout. By default, AbstractCorrelatingMessageHandler.afterRelease(MessageGroup, Collection) is invoked.

Overrides:

afterRelease in class AbstractCorrelatingMessageHandler

Parameters:

messageGroup - The group.

completedMessages - The completed messages.

timeout - True if the release/discard was due to a timeout.