public class AggregatingMessageHandler extends AbstractCorrelatingMessageHandler
AbstractCorrelatingMessageHandler.
Will remove MessageGroups in the afterRelease(org.springframework.integration.store.MessageGroup, java.util.CollectionDEFAULT_SEND_TIMEOUT, messageStore| 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
|
findLastReleasedSequenceNumber, getComponentType, getMessageStore, handleMessageInternal, onInit, setCorrelationStrategy, setDiscardChannel, setLockRegistry, setMessageStore, setMinimumTimeoutForEmptyGroups, setOutputChannel, setReleasePartialSequences, setReleaseStrategy, setSendPartialResultOnExpiry, setSendTimeoutgetOrder, handleMessage, setOrder, setShouldTrackafterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setTaskScheduler, 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)
protected void afterRelease(MessageGroup messageGroup, java.util.Collection<org.springframework.messaging.Message<?>> completedMessages)
AbstractCorrelatingMessageHandlerafterRelease in class AbstractCorrelatingMessageHandler