public class AggregatingMessageHandler extends AbstractCorrelatingMessageHandler
AbstractCorrelatingMessageHandler.
Will remove MessageGroups in the afterRelease(org.springframework.integration.store.MessageGroup, java.util.CollectionAbstractCorrelatingMessageHandler.SequenceAwareMessageGroupDEFAULT_SEND_TIMEOUT, messageStoreHIGHEST_PRECEDENCE, LOWEST_PRECEDENCE| 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<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.
|
completeGroup, completeGroup, destroy, expireGroup, findLastReleasedSequenceNumber, getComponentType, getCorrelationStrategy, getDiscardChannel, getDiscardChannelName, getEvaluationContext, getExpireGroupScheduledFutures, getGroupTimeoutExpression, getLockRegistry, getMessageStore, getMessagingTemplate, getMinimumTimeoutForEmptyGroups, getOutputChannel, getOutputChannelName, getOutputProcessor, getReleaseStrategy, handleMessageInternal, isLockRegistrySet, isReleasePartialSequences, isSendPartialResultOnExpiry, isSequenceAware, obtainGroupTimeout, onInit, sendReplies, sendReplyMessage, setApplicationEventPublisher, setCorrelationStrategy, setDiscardChannel, setDiscardChannelName, setGroupTimeoutExpression, setIntegrationEvaluationContext, setLockRegistry, setMessageStore, setMinimumTimeoutForEmptyGroups, setOutputChannel, setOutputChannelName, setReleasePartialSequences, setReleaseStrategy, setSendPartialResultOnExpiry, setSendTimeout, setTaskScheduler, shouldSendMultipleReplies, store, verifyResultCollectionConsistsOfMessagesgetOrder, handleMessage, setOrder, setShouldTrackafterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setMessageBuilderFactory, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetComponentNamepublic 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<?>>)protected void afterRelease(MessageGroup messageGroup, java.util.Collection<Message<?>> completedMessages)
AbstractCorrelatingMessageHandlerafterRelease in class AbstractCorrelatingMessageHandlermessageGroup - The group.completedMessages - The completed messages.