Package org.springframework.integration.config

Class AggregatorFactoryBean

java.lang.Object

org.springframework.integration.config.AbstractSimpleMessageHandlerFactoryBean<AggregatingMessageHandler>

org.springframework.integration.config.AggregatorFactoryBean

All Implemented Interfaces:

Aware, BeanFactoryAware, BeanNameAware, FactoryBean<MessageHandler>, ApplicationContextAware, ApplicationEventPublisherAware

public class AggregatorFactoryBean
extends AbstractSimpleMessageHandlerFactoryBean<AggregatingMessageHandler>

FactoryBean to create an AggregatingMessageHandler.

Since:

4.2

Author:

Gary Russell, Artem Bilan, Ngoc Nhan

Field Summary

Fields inherited from class org.springframework.integration.config.AbstractSimpleMessageHandlerFactoryBean

logger

Fields inherited from interface org.springframework.beans.factory.FactoryBean

OBJECT_TYPE_ATTRIBUTE

Constructor Summary

Constructors

Constructor	Description
AggregatorFactoryBean()

Method Summary

Modifier and Type	Method	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	setDiscardChannel(MessageChannel discardChannel)
void	setDiscardChannelName(String discardChannelName)
void	setDiscardIndividuallyOnExpiry(Boolean discardIndividuallyOnExpiry)	Set to false to send to discard channel a whole expired group as a single message.
void	setExpireDurationMillis(Long expireDuration)
void	setExpireGroupsUponCompletion(Boolean expireGroupsUponCompletion)
void	setExpireGroupsUponTimeout(Boolean expireGroupsUponTimeout)
void	setExpireTimeout(Long expireTimeout)
void	setForceReleaseAdviceChain(List<Advice> forceReleaseAdviceChain)
void	setGroupConditionSupplier(BiFunction<Message<?>,String,String> groupConditionSupplier)
void	setGroupTimeoutExpression(Expression groupTimeoutExpression)
void	setHeadersFunction(Function<MessageGroup,Map<String,Object>> headersFunction)
void	setLockRegistry(LockRegistry lockRegistry)
void	setMessageStore(MessageGroupStore messageStore)
void	setMethodName(String methodName)
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	setTaskScheduler(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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AggregatorFactoryBean

public AggregatorFactoryBean()

Method Details

setProcessorBean

public void setProcessorBean(Object processorBean)

setMethodName

public void setMethodName(String methodName)

setExpireGroupsUponCompletion

public void setExpireGroupsUponCompletion(Boolean expireGroupsUponCompletion)

setSendTimeout

public void setSendTimeout(Long sendTimeout)

setOutputChannelName

public void setOutputChannelName(String outputChannelName)

Description copied from class: AbstractSimpleMessageHandlerFactoryBean

Set the handler's output channel name.

Overrides:

setOutputChannelName in class AbstractSimpleMessageHandlerFactoryBean<AggregatingMessageHandler>

Parameters:

outputChannelName - the output channel bean name to set.

setLockRegistry

public void setLockRegistry(LockRegistry lockRegistry)

setMessageStore

public void setMessageStore(MessageGroupStore messageStore)

setCorrelationStrategy

public void setCorrelationStrategy(CorrelationStrategy correlationStrategy)

setReleaseStrategy

public void setReleaseStrategy(ReleaseStrategy releaseStrategy)

setGroupTimeoutExpression

public void setGroupTimeoutExpression(Expression groupTimeoutExpression)

setForceReleaseAdviceChain

public void setForceReleaseAdviceChain(List<Advice> forceReleaseAdviceChain)

setTaskScheduler

public void setTaskScheduler(TaskScheduler taskScheduler)

setDiscardChannel

public void setDiscardChannel(MessageChannel discardChannel)

setDiscardChannelName

public void setDiscardChannelName(String discardChannelName)

setSendPartialResultOnExpiry

public void setSendPartialResultOnExpiry(Boolean sendPartialResultOnExpiry)

setMinimumTimeoutForEmptyGroups

public void setMinimumTimeoutForEmptyGroups(Long minimumTimeoutForEmptyGroups)

setExpireGroupsUponTimeout

public void setExpireGroupsUponTimeout(Boolean expireGroupsUponTimeout)

setPopSequence

public void setPopSequence(Boolean popSequence)

setReleaseLockBeforeSend

public void setReleaseLockBeforeSend(Boolean releaseLockBeforeSend)

setHeadersFunction

public void setHeadersFunction(Function<MessageGroup,Map<String,Object>> headersFunction)

setExpireTimeout

public void setExpireTimeout(Long expireTimeout)

setExpireDurationMillis

public void setExpireDurationMillis(Long expireDuration)

setGroupConditionSupplier

public void setGroupConditionSupplier(BiFunction<Message<?>,String,String> groupConditionSupplier)

setDiscardIndividuallyOnExpiry

public void setDiscardIndividuallyOnExpiry(Boolean discardIndividuallyOnExpiry)

Set to false to send to discard channel a whole expired group as a single message.

Parameters:

discardIndividuallyOnExpiry - false to discard the whole group as one message.

Since:

6.5

See Also:

• AbstractCorrelatingMessageHandler.setDiscardIndividuallyOnExpiry(boolean)

createHandler

protected AggregatingMessageHandler createHandler()

Specified by:

createHandler in class AbstractSimpleMessageHandlerFactoryBean<AggregatingMessageHandler>

getPreCreationHandlerType

protected Class<? extends MessageHandler> getPreCreationHandlerType()

Description copied from class: AbstractSimpleMessageHandlerFactoryBean

Subclasses can override this to return a more specific type before handler creation. After handler creation, the actual type is used.

Overrides:

getPreCreationHandlerType in class AbstractSimpleMessageHandlerFactoryBean<AggregatingMessageHandler>

Returns:

the type.