public class AggregatorFactoryBean extends AbstractSimpleMessageHandlerFactoryBean<AggregatingMessageHandler> implements ApplicationContextAware, BeanNameAware, ApplicationEventPublisherAware
FactoryBean to create an AggregatingMessageHandler.logger| Constructor and Description |
|---|
AggregatorFactoryBean(Object processor) |
AggregatorFactoryBean(Object processor,
String methodName) |
createHandlerInternal, getBeanFactory, getObject, getObjectType, isSingleton, setAdviceChain, setBeanFactory, setComponentName, setOrder, setOutputChannelpublic AggregatorFactoryBean(Object processor)
public void setExpireGroupsUponCompletion(boolean expireGroupsUponCompletion)
public void setSendTimeout(long sendTimeout)
public void setOutputChannelName(String outputChannelName)
public void configureMetrics(AbstractMessageHandlerMetrics metrics)
public final void setBeanName(String beanName)
setBeanName in interface BeanNameAwarepublic void setApplicationContext(ApplicationContext applicationContext) throws BeansException
setApplicationContext in interface ApplicationContextAwareBeansExceptionpublic void setChannelResolver(DestinationResolver<MessageChannel> channelResolver)
public void enableStats(boolean statsEnabled)
public void enableCounts(boolean countsEnabled)
public void setLockRegistry(LockRegistry lockRegistry)
public void setMessageStore(MessageGroupStore store)
public void setCorrelationStrategy(CorrelationStrategy correlationStrategy)
public void setReleaseStrategy(ReleaseStrategy releaseStrategy)
public void setGroupTimeoutExpression(Expression groupTimeoutExpression)
public void setForceReleaseAdviceChain(List<org.aopalliance.aop.Advice> forceReleaseAdviceChain)
public void setTaskScheduler(TaskScheduler taskScheduler)
public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
setApplicationEventPublisher in interface ApplicationEventPublisherAwarepublic void setDiscardChannel(MessageChannel discardChannel)
public void setDiscardChannelName(String discardChannelName)
public void setSendPartialResultOnExpiry(boolean sendPartialResultOnExpiry)
public void setMinimumTimeoutForEmptyGroups(long minimumTimeoutForEmptyGroups)
public void setReleasePartialSequences(boolean releasePartialSequences)
public void setExpireGroupsUponTimeout(boolean expireGroupsUponTimeout)
protected AggregatingMessageHandler createHandler()
createHandler in class AbstractSimpleMessageHandlerFactoryBean<AggregatingMessageHandler>