Class AggregatorFactoryBean
java.lang.Object
org.springframework.integration.config.AbstractSimpleMessageHandlerFactoryBean<AggregatingMessageHandler>
org.springframework.integration.config.AggregatorFactoryBean
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.BeanNameAware,org.springframework.beans.factory.FactoryBean<org.springframework.messaging.MessageHandler>,org.springframework.context.ApplicationContextAware,org.springframework.context.ApplicationEventPublisherAware
public class AggregatorFactoryBean extends AbstractSimpleMessageHandlerFactoryBean<AggregatingMessageHandler>
FactoryBean to create an
AggregatingMessageHandler.- Since:
- 4.2
-
Field Summary
Fields inherited from class org.springframework.integration.config.AbstractSimpleMessageHandlerFactoryBean
logger -
Constructor Summary
Constructors Constructor Description AggregatorFactoryBean() -
Method Summary
Modifier and Type Method Description protected AggregatingMessageHandlercreateHandler()protected java.lang.Class<? extends org.springframework.messaging.MessageHandler>getPreCreationHandlerType()Subclasses can override this to return a more specific type before handler creation.voidsetCorrelationStrategy(CorrelationStrategy correlationStrategy)voidsetDiscardChannel(org.springframework.messaging.MessageChannel discardChannel)voidsetDiscardChannelName(java.lang.String discardChannelName)voidsetExpireDurationMillis(java.lang.Long expireDuration)voidsetExpireGroupsUponCompletion(java.lang.Boolean expireGroupsUponCompletion)voidsetExpireGroupsUponTimeout(java.lang.Boolean expireGroupsUponTimeout)voidsetExpireTimeout(java.lang.Long expireTimeout)voidsetForceReleaseAdviceChain(java.util.List<org.aopalliance.aop.Advice> forceReleaseAdviceChain)voidsetGroupTimeoutExpression(org.springframework.expression.Expression groupTimeoutExpression)voidsetHeadersFunction(java.util.function.Function<MessageGroup,java.util.Map<java.lang.String,java.lang.Object>> headersFunction)voidsetLockRegistry(LockRegistry lockRegistry)voidsetMessageStore(MessageGroupStore messageStore)voidsetMethodName(java.lang.String methodName)voidsetMinimumTimeoutForEmptyGroups(java.lang.Long minimumTimeoutForEmptyGroups)voidsetOutputChannelName(java.lang.String outputChannelName)Set the handler's output channel name.voidsetPopSequence(java.lang.Boolean popSequence)voidsetProcessorBean(java.lang.Object processorBean)voidsetReleaseLockBeforeSend(java.lang.Boolean releaseLockBeforeSend)voidsetReleaseStrategy(ReleaseStrategy releaseStrategy)voidsetSendPartialResultOnExpiry(java.lang.Boolean sendPartialResultOnExpiry)voidsetSendTimeout(java.lang.Long sendTimeout)voidsetTaskScheduler(org.springframework.scheduling.TaskScheduler taskScheduler)Methods inherited from class org.springframework.integration.config.AbstractSimpleMessageHandlerFactoryBean
createHandlerInternal, getBeanFactory, getObject, getObjectType, isSingleton, setAdviceChain, setApplicationContext, setApplicationEventPublisher, setAsync, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setOrder, setOutputChannel
-
Constructor Details
-
AggregatorFactoryBean
public AggregatorFactoryBean()
-
-
Method Details
-
setProcessorBean
public void setProcessorBean(java.lang.Object processorBean) -
setMethodName
public void setMethodName(java.lang.String methodName) -
setExpireGroupsUponCompletion
public void setExpireGroupsUponCompletion(java.lang.Boolean expireGroupsUponCompletion) -
setSendTimeout
public void setSendTimeout(java.lang.Long sendTimeout) -
setOutputChannelName
public void setOutputChannelName(java.lang.String outputChannelName)Description copied from class:AbstractSimpleMessageHandlerFactoryBeanSet the handler's output channel name.- Overrides:
setOutputChannelNamein classAbstractSimpleMessageHandlerFactoryBean<AggregatingMessageHandler>- Parameters:
outputChannelName- the output channel bean name to set.
-
setLockRegistry
-
setMessageStore
-
setCorrelationStrategy
-
setReleaseStrategy
-
setGroupTimeoutExpression
public void setGroupTimeoutExpression(org.springframework.expression.Expression groupTimeoutExpression) -
setForceReleaseAdviceChain
public void setForceReleaseAdviceChain(java.util.List<org.aopalliance.aop.Advice> forceReleaseAdviceChain) -
setTaskScheduler
public void setTaskScheduler(org.springframework.scheduling.TaskScheduler taskScheduler) -
setDiscardChannel
public void setDiscardChannel(org.springframework.messaging.MessageChannel discardChannel) -
setDiscardChannelName
public void setDiscardChannelName(java.lang.String discardChannelName) -
setSendPartialResultOnExpiry
public void setSendPartialResultOnExpiry(java.lang.Boolean sendPartialResultOnExpiry) -
setMinimumTimeoutForEmptyGroups
public void setMinimumTimeoutForEmptyGroups(java.lang.Long minimumTimeoutForEmptyGroups) -
setExpireGroupsUponTimeout
public void setExpireGroupsUponTimeout(java.lang.Boolean expireGroupsUponTimeout) -
setPopSequence
public void setPopSequence(java.lang.Boolean popSequence) -
setReleaseLockBeforeSend
public void setReleaseLockBeforeSend(java.lang.Boolean releaseLockBeforeSend) -
setHeadersFunction
public void setHeadersFunction(java.util.function.Function<MessageGroup,java.util.Map<java.lang.String,java.lang.Object>> headersFunction) -
setExpireTimeout
public void setExpireTimeout(java.lang.Long expireTimeout) -
setExpireDurationMillis
public void setExpireDurationMillis(java.lang.Long expireDuration) -
createHandler
- Specified by:
createHandlerin classAbstractSimpleMessageHandlerFactoryBean<AggregatingMessageHandler>
-
getPreCreationHandlerType
protected java.lang.Class<? extends org.springframework.messaging.MessageHandler> getPreCreationHandlerType()Description copied from class:AbstractSimpleMessageHandlerFactoryBeanSubclasses can override this to return a more specific type before handler creation. After handler creation, the actual type is used.- Overrides:
getPreCreationHandlerTypein classAbstractSimpleMessageHandlerFactoryBean<AggregatingMessageHandler>- Returns:
- the type.
-