クラス ScatterGatherSpec
java.lang.ObjectSE
org.springframework.integration.dsl.IntegrationComponentSpec < ScatterGatherSpec、reacters.util.function.Tuple2< ConsumerEndpointFactoryBean、ScatterGatherHandler >>
org.springframework.integration.dsl.EndpointSpec<ScatterGatherSpec,ConsumerEndpointFactoryBean,ScatterGatherHandler>
org.springframework.integration.dsl.ConsumerEndpointSpec<ScatterGatherSpec,ScatterGatherHandler>
org.springframework.integration.dsl.ScatterGatherSpec
- 実装されたすべてのインターフェース:
DisposableBean
、FactoryBean<reactor.util.function.Tuple2<ConsumerEndpointFactoryBean,
、ScatterGatherHandler>> InitializingBean
、Lifecycle
、Phased
、SmartLifecycle
、ComponentsRegistration
- 導入:
- 5.0
- 作成者:
- Artem Bilan, Gary Russell
- 関連事項:
フィールドのサマリー
クラス org.springframework.integration.dsl.ConsumerEndpointSpec から継承されたフィールド
adviceChain
クラス org.springframework.integration.dsl.EndpointSpec から継承されたフィールド
componentsToRegister, endpointFactoryBean, handler
クラス org.springframework.integration.dsl.IntegrationComponentSpec から継承されたフィールド
logger, PARSER, target
インターフェース org.springframework.beans.factory.FactoryBean から継承されたフィールド
OBJECT_TYPE_ATTRIBUTE
インターフェース org.springframework.context.SmartLifecycle から継承されたフィールド
DEFAULT_PHASE
コンストラクターの概要
コンストラクターメソッドのサマリー
修飾子と型メソッド説明errorChannel
(StringSE errorChannel) 非同期エラー処理のMessageChannel
Bean 名を指定します。gatherChannel
(MessageChannel gatherChannel) 分散したリクエストの結果を収集(集約)するためにScatterGatherHandler
で内部的に使用されるMessageChannel
(オプション)を指定します。gatherTimeout
(long gatherTimeout) PollableChannel.receive(long)
操作が結果を収集して出力するのを待つタイムアウト(ミリ秒単位)を指定します。クラス org.springframework.integration.dsl.ConsumerEndpointSpec から継承されたメソッド
advice, async, autoStartup, customizeMonoReply, doGet, handleMessageAdvice, notPropagatedHeaders, order, phase, poller, reactive, reactive, requiresReply, role, sendTimeout, taskScheduler, transactional, transactional, transactional, transactional, transactional
クラス org.springframework.integration.dsl.EndpointSpec から継承されたメソッド
assertHandler, getComponentsToRegister, id, obtainInputChannelFromFlow, obtainInputChannelFromFlow, poller, poller
クラス org.springframework.integration.dsl.IntegrationComponentSpec から継承されたメソッド
_this, afterPropertiesSet, destroy, getId, getObject, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE
インターフェース org.springframework.beans.factory.FactoryBean から継承されたメソッド
isSingleton
コンストラクターの詳細
ScatterGatherSpec
メソッドの詳細
gatherChannel
分散したリクエストの結果を収集(集約)するためにScatterGatherHandler
で内部的に使用されるMessageChannel
(オプション)を指定します。- パラメーター:
gatherChannel
- 結果を収集するためのMessageChannel
。- 戻り値:
- 現在の
ScatterGatherSpec
インスタンス。
gatherTimeout
PollableChannel.receive(long)
操作が収集結果の出力を待機するタイムアウト (ミリ秒) を指定します。デフォルトは30
秒です。- パラメーター:
gatherTimeout
-PollableChannel
受信タイムアウト。- 戻り値:
- 現在の
ScatterGatherSpec
インスタンス。
errorChannel
非同期エラー処理のMessageChannel
Bean 名を指定します。デフォルトはIntegrationContextUtils.ERROR_CHANNEL_BEAN_NAME
です。- パラメーター:
errorChannel
- 非同期エラー処理のMessageChannel
Bean 名。- 戻り値:
- 現在の
ScatterGatherSpec
インスタンス。 - 導入:
- 5.1.3