クラス ScatterGatherSpec
java.lang.ObjectSE
org.springframework.integration.dsl.IntegrationComponentSpec <S、reactor.util.function.Tuple2<F、H>>
org.springframework.integration.dsl.EndpointSpec<S,ConsumerEndpointFactoryBean,H>
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) 非同期エラー処理のMessageChannelBean 名を指定します。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
非同期エラー処理のMessageChannelBean 名を指定します。デフォルトはIntegrationContextUtils.ERROR_CHANNEL_BEAN_NAMEです。- パラメーター:
errorChannel- 非同期エラー処理のMessageChannelBean 名。- 戻り値:
- 現在の
ScatterGatherSpecインスタンス。 - 導入:
- 5.1.3