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 |
setHeadersFunction(java.util.function.Function<MessageGroup,java.util.Map<java.lang.String,java.lang.Object>> headersFunction) |
void |
setLockRegistry(LockRegistry lockRegistry) |
void |
setMessageStore(MessageGroupStore messageStore) |
void |
setMethodName(java.lang.String methodName) |
void |
setMetrics(AbstractMessageHandlerMetrics metrics)
Deprecated.
in favor of Micrometer metrics.
|
void |
setMinimumTimeoutForEmptyGroups(java.lang.Long minimumTimeoutForEmptyGroups) |
void |
setOutputChannelName(java.lang.String outputChannelName)
Set the handler's output channel name.
|
void |
setPopSequence(java.lang.Boolean popSequence) |
void |
setProcessorBean(java.lang.Object processorBean) |
void |
setReleaseLockBeforeSend(java.lang.Boolean releaseLockBeforeSend) |
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, setOutputChannelpublic 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)
AbstractSimpleMessageHandlerFactoryBeansetOutputChannelName in class AbstractSimpleMessageHandlerFactoryBean<AggregatingMessageHandler>outputChannelName - the output channel bean name to set.@Deprecated public void setMetrics(AbstractMessageHandlerMetrics metrics)
metrics - the 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)
public void setPopSequence(java.lang.Boolean popSequence)
public void setReleaseLockBeforeSend(java.lang.Boolean releaseLockBeforeSend)
public void setHeadersFunction(java.util.function.Function<MessageGroup,java.util.Map<java.lang.String,java.lang.Object>> headersFunction)
protected AggregatingMessageHandler createHandler()
createHandler in class AbstractSimpleMessageHandlerFactoryBean<AggregatingMessageHandler>protected java.lang.Class<? extends org.springframework.messaging.MessageHandler> getPreCreationHandlerType()
AbstractSimpleMessageHandlerFactoryBeangetPreCreationHandlerType in class AbstractSimpleMessageHandlerFactoryBean<AggregatingMessageHandler>