public class AggregatorFactoryBean extends AbstractSimpleMessageHandlerFactoryBean<AggregatingMessageHandler>
FactoryBean
を使用して AggregatingMessageHandler
を作成します。logger
OBJECT_TYPE_ATTRIBUTE
コンストラクターと説明 |
---|
AggregatorFactoryBean() |
createHandlerInternal, getBeanFactory, getObject, getObjectType, isSingleton, setAdviceChain, setApplicationContext, setApplicationEventPublisher, setAsync, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setOrder, setOutputChannel
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
public void setProcessorBean(ObjectSE processorBean)
public void setMethodName(StringSE methodName)
public void setExpireGroupsUponCompletion(BooleanSE expireGroupsUponCompletion)
public void setSendTimeout(LongSE sendTimeout)
public void setOutputChannelName(StringSE outputChannelName)
AbstractSimpleMessageHandlerFactoryBean
AbstractSimpleMessageHandlerFactoryBean<AggregatingMessageHandler>
の setOutputChannelName
outputChannelName
- 設定する出力チャネル Bean 名。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(ListSE<Advice> forceReleaseAdviceChain)
public void setTaskScheduler(TaskScheduler taskScheduler)
public void setDiscardChannel(MessageChannel discardChannel)
public void setDiscardChannelName(StringSE discardChannelName)
public void setSendPartialResultOnExpiry(BooleanSE sendPartialResultOnExpiry)
public void setMinimumTimeoutForEmptyGroups(LongSE minimumTimeoutForEmptyGroups)
public void setExpireGroupsUponTimeout(BooleanSE expireGroupsUponTimeout)
public void setPopSequence(BooleanSE popSequence)
public void setReleaseLockBeforeSend(BooleanSE releaseLockBeforeSend)
public void setHeadersFunction(java.util.function.FunctionSE<MessageGroup,MapSE<StringSE,ObjectSE>> headersFunction)
public void setExpireTimeout(LongSE expireTimeout)
public void setExpireDurationMillis(LongSE expireDuration)
protected AggregatingMessageHandler createHandler()
protected ClassSE<? extends MessageHandler> getPreCreationHandlerType()
AbstractSimpleMessageHandlerFactoryBean
AbstractSimpleMessageHandlerFactoryBean<AggregatingMessageHandler>
の getPreCreationHandlerType