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
loggerFields inherited from interface org.springframework.beans.factory.FactoryBean
OBJECT_TYPE_ATTRIBUTE -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected AggregatingMessageHandlerprotected Class<? extends org.springframework.messaging.MessageHandler>Subclasses can override this to return a more specific type before handler creation.voidsetCorrelationStrategy(CorrelationStrategy correlationStrategy) voidsetDiscardChannel(org.springframework.messaging.MessageChannel discardChannel) voidsetDiscardChannelName(String discardChannelName) voidsetExpireDurationMillis(Long expireDuration) voidsetExpireGroupsUponCompletion(Boolean expireGroupsUponCompletion) voidsetExpireGroupsUponTimeout(Boolean expireGroupsUponTimeout) voidsetExpireTimeout(Long expireTimeout) voidsetForceReleaseAdviceChain(List<org.aopalliance.aop.Advice> forceReleaseAdviceChain) voidsetGroupConditionSupplier(BiFunction<org.springframework.messaging.Message<?>, String, String> groupConditionSupplier) voidsetGroupTimeoutExpression(org.springframework.expression.Expression groupTimeoutExpression) voidsetHeadersFunction(Function<MessageGroup, Map<String, Object>> headersFunction) voidsetLockRegistry(LockRegistry lockRegistry) voidsetMessageStore(MessageGroupStore messageStore) voidsetMethodName(String methodName) voidsetMinimumTimeoutForEmptyGroups(Long minimumTimeoutForEmptyGroups) voidsetOutputChannelName(String outputChannelName) Set the handler's output channel name.voidsetPopSequence(Boolean popSequence) voidsetProcessorBean(Object processorBean) voidsetReleaseLockBeforeSend(Boolean releaseLockBeforeSend) voidsetReleaseStrategy(ReleaseStrategy releaseStrategy) voidsetSendPartialResultOnExpiry(Boolean sendPartialResultOnExpiry) voidsetSendTimeout(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
-
setMethodName
-
setExpireGroupsUponCompletion
-
setSendTimeout
-
setOutputChannelName
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
-
setTaskScheduler
public void setTaskScheduler(org.springframework.scheduling.TaskScheduler taskScheduler) -
setDiscardChannel
public void setDiscardChannel(org.springframework.messaging.MessageChannel discardChannel) -
setDiscardChannelName
-
setSendPartialResultOnExpiry
-
setMinimumTimeoutForEmptyGroups
-
setExpireGroupsUponTimeout
-
setPopSequence
-
setReleaseLockBeforeSend
-
setHeadersFunction
-
setExpireTimeout
-
setExpireDurationMillis
-
setGroupConditionSupplier
public void setGroupConditionSupplier(BiFunction<org.springframework.messaging.Message<?>, String, String> groupConditionSupplier) -
createHandler
- Specified by:
createHandlerin classAbstractSimpleMessageHandlerFactoryBean<AggregatingMessageHandler>
-
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.
-