public class ScatterGatherSpec extends ConsumerEndpointSpec<ScatterGatherSpec,ScatterGatherHandler>
ScatterGatherHandleradviceChaincomponentsToRegister, endpointFactoryBean, handlerPARSER, targetloggerDEFAULT_PHASEOBJECT_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, transactionalassertHandler, getComponentsToRegister, id, obtainInputChannelFromFlow, obtainInputChannelFromFlow, poller, poller_this, createInstance, destroyInstance, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stopafterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingletoncloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEprotected 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 インスタンス。