クラス ScatterGatherSpec
java.lang.ObjectSE
org.springframework.integration.dsl.IntegrationComponentSpec<ScatterGatherSpec, reactor.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
public class ScatterGatherSpec
extends ConsumerEndpointSpec<ScatterGatherSpec, ScatterGatherHandler>
- 導入:
- 5.0
- 作成者:
- Artem Bilan, Gary Russell
- 関連事項:
フィールド概要
クラス ConsumerEndpointSpec から継承されたフィールド
adviceChainクラス EndpointSpec から継承されたフィールド
componentsToRegister, endpointFactoryBean, handlerクラス IntegrationComponentSpec から継承されたフィールド
logger, PARSER, targetインターフェース FactoryBean から継承されたフィールド
OBJECT_TYPE_ATTRIBUTEインターフェース SmartLifecycle から継承されたフィールド
DEFAULT_PHASEコンストラクター概要
コンストラクター方法の概要
修飾子と型メソッド説明errorChannel(StringSE errorChannel) 非同期エラー処理のMessageChannelBean 名を指定します。gatherChannel(MessageChannel gatherChannel) 分散したリクエストの結果を収集（集約）するためにScatterGatherHandlerで内部的に使用されるMessageChannel（オプション）を指定します。gatherTimeout(long gatherTimeout) PollableChannel.receive(long)操作が結果を収集して出力するのを待つタイムアウト（ミリ秒単位）を指定します。クラス ConsumerEndpointSpec から継承されたメソッド
advice, async, autoStartup, customizeMonoReply, doGet, handleMessageAdvice, notPropagatedHeaders, order, phase, poller, reactive, reactive, requiresReply, role, sendTimeout, taskScheduler, transactional, transactional, transactional, transactional, transactionalクラス EndpointSpec から継承されたメソッド
getComponentsToRegister, id, obtainInputChannelFromFlow, obtainInputChannelFromFlow, poller, pollerクラス IntegrationComponentSpec から継承されたメソッド
_this, afterPropertiesSet, destroy, getId, getObject, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stopクラス ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSEインターフェース FactoryBean から継承されたメソッド
isSingletonインターフェース SmartLifecycle から継承されたメソッド
isPauseable
コンストラクターの詳細
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