public class AggregatorFactoryBean extends AbstractSimpleMessageHandlerFactoryBean<AggregatingMessageHandler>
FactoryBean
to create an
AggregatingMessageHandler
.logger
OBJECT_TYPE_ATTRIBUTE
Constructor and Description |
---|
AggregatorFactoryBean() |
Modifier and Type | Method and Description |
---|---|
protected AggregatingMessageHandler |
createHandler() |
protected Class<? extends MessageHandler> |
getPreCreationHandlerType()
Subclasses can override this to return a more specific type before handler creation.
|
void |
setCorrelationStrategy(CorrelationStrategy correlationStrategy) |
void |
setCountsEnabled(Boolean countsEnabled) |
void |
setDiscardChannel(MessageChannel discardChannel) |
void |
setDiscardChannelName(String discardChannelName) |
void |
setExpireGroupsUponCompletion(Boolean expireGroupsUponCompletion) |
void |
setExpireGroupsUponTimeout(Boolean expireGroupsUponTimeout) |
void |
setForceReleaseAdviceChain(List<Advice> forceReleaseAdviceChain) |
void |
setGroupTimeoutExpression(Expression groupTimeoutExpression) |
void |
setHeadersFunction(java.util.function.Function<MessageGroup,Map<String,Object>> headersFunction) |
void |
setLockRegistry(LockRegistry lockRegistry) |
void |
setMessageStore(MessageGroupStore messageStore) |
void |
setMethodName(String methodName) |
void |
setMetrics(AbstractMessageHandlerMetrics metrics)
Deprecated.
in favor of Micrometer metrics.
|
void |
setMinimumTimeoutForEmptyGroups(Long minimumTimeoutForEmptyGroups) |
void |
setOutputChannelName(String outputChannelName)
Set the handler's output channel name.
|
void |
setPopSequence(Boolean popSequence) |
void |
setProcessorBean(Object processorBean) |
void |
setReleaseLockBeforeSend(Boolean releaseLockBeforeSend) |
void |
setReleaseStrategy(ReleaseStrategy releaseStrategy) |
void |
setSendPartialResultOnExpiry(Boolean sendPartialResultOnExpiry) |
void |
setSendTimeout(Long sendTimeout) |
void |
setStatsEnabled(Boolean statsEnabled) |
void |
setTaskScheduler(TaskScheduler taskScheduler) |
createHandlerInternal, getBeanFactory, getObject, getObjectType, isSingleton, setAdviceChain, setApplicationContext, setApplicationEventPublisher, setAsync, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setOrder, setOutputChannel
public void setProcessorBean(Object processorBean)
public void setMethodName(String methodName)
public void setExpireGroupsUponCompletion(Boolean expireGroupsUponCompletion)
public void setSendTimeout(Long sendTimeout)
public void setOutputChannelName(String outputChannelName)
AbstractSimpleMessageHandlerFactoryBean
setOutputChannelName
in class AbstractSimpleMessageHandlerFactoryBean<AggregatingMessageHandler>
outputChannelName
- the output channel bean name to set.@Deprecated public void setMetrics(AbstractMessageHandlerMetrics metrics)
metrics
- the metrics.public void setStatsEnabled(Boolean statsEnabled)
public void setCountsEnabled(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(Expression groupTimeoutExpression)
public void setForceReleaseAdviceChain(List<Advice> forceReleaseAdviceChain)
public void setTaskScheduler(TaskScheduler taskScheduler)
public void setDiscardChannel(MessageChannel discardChannel)
public void setDiscardChannelName(String discardChannelName)
public void setSendPartialResultOnExpiry(Boolean sendPartialResultOnExpiry)
public void setMinimumTimeoutForEmptyGroups(Long minimumTimeoutForEmptyGroups)
public void setExpireGroupsUponTimeout(Boolean expireGroupsUponTimeout)
public void setPopSequence(Boolean popSequence)
public void setReleaseLockBeforeSend(Boolean releaseLockBeforeSend)
public void setHeadersFunction(java.util.function.Function<MessageGroup,Map<String,Object>> headersFunction)
protected AggregatingMessageHandler createHandler()
createHandler
in class AbstractSimpleMessageHandlerFactoryBean<AggregatingMessageHandler>
protected Class<? extends MessageHandler> getPreCreationHandlerType()
AbstractSimpleMessageHandlerFactoryBean
getPreCreationHandlerType
in class AbstractSimpleMessageHandlerFactoryBean<AggregatingMessageHandler>