public class ScatterGatherSpec extends ConsumerEndpointSpec<ScatterGatherSpec,ScatterGatherHandler>
ScatterGatherHandler
adviceChain
componentsToRegister, endpointFactoryBean, handler
PARSER, target
logger
DEFAULT_PHASE
OBJECT_TYPE_ATTRIBUTE
修飾子 | コンストラクターと説明 |
---|---|
protected | ScatterGatherSpec(ScatterGatherHandler messageHandler) |
修飾子と型 | メソッドと説明 |
---|---|
ScatterGatherSpec | errorChannel(StringSE errorChannel) 非同期エラー処理の MessageChannel Bean 名を指定します。 |
ScatterGatherSpec | gatherChannel(MessageChannel gatherChannel) 分散したリクエストの結果を収集(集約)するために ScatterGatherHandler で内部的に使用される MessageChannel (オプション)を指定します。 |
ScatterGatherSpec | gatherTimeout(long gatherTimeout) PollableChannel.receive(long) 操作が結果を収集して出力するのを待つタイムアウト(ミリ秒単位)を指定します。 |
advice, async, autoStartup, customizeMonoReply, doGet, handleMessageAdvice, notPropagatedHeaders, order, phase, poller, requiresReply, role, sendTimeout, taskScheduler, transactional, transactional, transactional, transactional, transactional
assertHandler, getComponentsToRegister, id, obtainInputChannelFromFlow, obtainInputChannelFromFlow, poller, poller
_this, createInstance, destroyInstance, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
protected ScatterGatherSpec(ScatterGatherHandler messageHandler)
public ScatterGatherSpec gatherChannel(MessageChannel gatherChannel)
ScatterGatherHandler
で内部的に使用される MessageChannel
(オプション)を指定します。gatherChannel
- 結果を収集するための MessageChannel
。ScatterGatherSpec
インスタンス。public ScatterGatherSpec gatherTimeout(long gatherTimeout)
PollableChannel.receive(long)
操作が結果を収集して出力するのを待つタイムアウト(ミリ秒単位)を指定します。デフォルトは -1
です - 無期限に待機します。gatherTimeout
- PollableChannel
受信タイムアウト。ScatterGatherSpec
インスタンス。public ScatterGatherSpec errorChannel(StringSE errorChannel)
MessageChannel
Bean 名を指定します。デフォルトは IntegrationContextUtils.ERROR_CHANNEL_BEAN_NAME
です。errorChannel
- 非同期エラー処理の MessageChannel
Bean 名。ScatterGatherSpec
インスタンス。