public class AggregatorFactoryBean extends AbstractSimpleMessageHandlerFactoryBean<AggregatingMessageHandler>
FactoryBean
to create an AggregatingMessageHandler
.logger
Constructor and Description |
---|
AggregatorFactoryBean() |
Modifier and Type | Method and Description |
---|---|
protected AggregatingMessageHandler |
createHandler() |
protected java.lang.Class<? extends org.springframework.messaging.MessageHandler> |
getPreCreationHandlerType()
Subclasses can override this to return a more specific type before handler creation.
|
void |
setCorrelationStrategy(CorrelationStrategy correlationStrategy) |
void |
setCountsEnabled(java.lang.Boolean countsEnabled) |
void |
setDiscardChannel(org.springframework.messaging.MessageChannel discardChannel) |
void |
setDiscardChannelName(java.lang.String discardChannelName) |
void |
setExpireGroupsUponCompletion(java.lang.Boolean expireGroupsUponCompletion) |
void |
setExpireGroupsUponTimeout(java.lang.Boolean expireGroupsUponTimeout) |
void |
setForceReleaseAdviceChain(java.util.List<org.aopalliance.aop.Advice> forceReleaseAdviceChain) |
void |
setGroupTimeoutExpression(org.springframework.expression.Expression groupTimeoutExpression) |
void |
setLockRegistry(LockRegistry lockRegistry) |
void |
setMessageStore(MessageGroupStore messageStore) |
void |
setMethodName(java.lang.String methodName) |
void |
setMetrics(AbstractMessageHandlerMetrics metrics) |
void |
setMinimumTimeoutForEmptyGroups(java.lang.Long minimumTimeoutForEmptyGroups) |
void |
setOutputChannelName(java.lang.String outputChannelName) |
void |
setProcessorBean(java.lang.Object processorBean) |
void |
setReleaseStrategy(ReleaseStrategy releaseStrategy) |
void |
setSendPartialResultOnExpiry(java.lang.Boolean sendPartialResultOnExpiry) |
void |
setSendTimeout(java.lang.Long sendTimeout) |
void |
setStatsEnabled(java.lang.Boolean statsEnabled) |
void |
setTaskScheduler(org.springframework.scheduling.TaskScheduler taskScheduler) |
createHandlerInternal, getBeanFactory, getObject, getObjectType, isSingleton, setAdviceChain, setApplicationContext, setApplicationEventPublisher, setAsync, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setOrder, setOutputChannel
public void setProcessorBean(java.lang.Object processorBean)
public void setMethodName(java.lang.String methodName)
public void setExpireGroupsUponCompletion(java.lang.Boolean expireGroupsUponCompletion)
public void setSendTimeout(java.lang.Long sendTimeout)
public void setOutputChannelName(java.lang.String outputChannelName)
public void setMetrics(AbstractMessageHandlerMetrics metrics)
public void setStatsEnabled(java.lang.Boolean statsEnabled)
public void setCountsEnabled(java.lang.Boolean countsEnabled)
public void setLockRegistry(LockRegistry lockRegistry)
public void setMessageStore(MessageGroupStore messageStore)
public void setCorrelationStrategy(CorrelationStrategy correlationStrategy)
public void setReleaseStrategy(ReleaseStrategy releaseStrategy)
public void setGroupTimeoutExpression(org.springframework.expression.Expression groupTimeoutExpression)
public void setForceReleaseAdviceChain(java.util.List<org.aopalliance.aop.Advice> forceReleaseAdviceChain)
public void setTaskScheduler(org.springframework.scheduling.TaskScheduler taskScheduler)
public void setDiscardChannel(org.springframework.messaging.MessageChannel discardChannel)
public void setDiscardChannelName(java.lang.String discardChannelName)
public void setSendPartialResultOnExpiry(java.lang.Boolean sendPartialResultOnExpiry)
public void setMinimumTimeoutForEmptyGroups(java.lang.Long minimumTimeoutForEmptyGroups)
public void setExpireGroupsUponTimeout(java.lang.Boolean expireGroupsUponTimeout)
protected AggregatingMessageHandler createHandler()
createHandler
in class AbstractSimpleMessageHandlerFactoryBean<AggregatingMessageHandler>
protected java.lang.Class<? extends org.springframework.messaging.MessageHandler> getPreCreationHandlerType()
AbstractSimpleMessageHandlerFactoryBean
getPreCreationHandlerType
in class AbstractSimpleMessageHandlerFactoryBean<AggregatingMessageHandler>