public class AggregatingMessageHandler extends AbstractCorrelatingMessageHandler
AbstractCorrelatingMessageHandler
.
Will remove MessageGroup
s in the afterRelease(org.springframework.integration.store.MessageGroup, java.util.CollectionAbstractCorrelatingMessageHandler.SequenceAwareMessageGroup
DEFAULT_SEND_TIMEOUT, messageStore
messagingTemplate
Constructor and Description |
---|
AggregatingMessageHandler(MessageGroupProcessor processor) |
AggregatingMessageHandler(MessageGroupProcessor processor,
MessageGroupStore store) |
AggregatingMessageHandler(MessageGroupProcessor processor,
MessageGroupStore store,
CorrelationStrategy correlationStrategy,
ReleaseStrategy releaseStrategy) |
Modifier and Type | Method and Description |
---|---|
protected void |
afterRelease(MessageGroup messageGroup,
java.util.Collection<org.springframework.messaging.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.
|
void |
setExpireGroupsUponTimeout(boolean expireGroupsOnTimeout)
Expire (completely remove) a group if it is completed due to timeout.
|
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, sendReplies, sendReplyMessage, setApplicationEventPublisher, setCorrelationStrategy, setDiscardChannel, setDiscardChannelName, setGroupTimeoutExpression, setIntegrationEvaluationContext, setLockRegistry, setMessageStore, setMinimumTimeoutForEmptyGroups, setReleasePartialSequences, setReleaseStrategy, setSendPartialResultOnExpiry, setTaskScheduler, shouldSendMultipleReplies, store, verifyResultCollectionConsistsOfMessages
getOutputChannel, setOutputChannel, setOutputChannelName, setSendTimeout
getOrder, handleMessage, setOrder, setShouldTrack
afterPropertiesSet, getApplicationContext, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setMessageBuilderFactory, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getComponentName
public AggregatingMessageHandler(MessageGroupProcessor processor, MessageGroupStore store, CorrelationStrategy correlationStrategy, ReleaseStrategy releaseStrategy)
public AggregatingMessageHandler(MessageGroupProcessor processor, MessageGroupStore store)
public AggregatingMessageHandler(MessageGroupProcessor processor)
public void setExpireGroupsUponCompletion(boolean expireGroupsUponCompletion)
expireGroupsUponCompletion
- true when groups should be expired on completion.afterRelease(org.springframework.integration.store.MessageGroup, java.util.Collection<org.springframework.messaging.Message<?>>)
public void setExpireGroupsUponTimeout(boolean expireGroupsOnTimeout)
AbstractCorrelatingMessageHandler
AbstractCorrelatingMessageHandler.afterRelease(MessageGroup, Collection)
.
Default true.setExpireGroupsUponTimeout
in class AbstractCorrelatingMessageHandler
expireGroupsOnTimeout
- the expireGroupsOnTimeout to setprotected void afterRelease(MessageGroup messageGroup, java.util.Collection<org.springframework.messaging.Message<?>> completedMessages)
AbstractCorrelatingMessageHandler
afterRelease
in class AbstractCorrelatingMessageHandler
messageGroup
- The group.completedMessages
- The completed messages.