public class StandardIntegrationFlow extends ObjectSE implements IntegrationFlow, SmartLifecycle
IntegrationFlow インターフェースの標準実装。統合フロー用に構成されたコンポーネントの論理コンテナーを表します。特に IntegrationFlowContext を使用して動的に宣言する場合は、単一のコンポーネントとして扱うことができます。 このクラスは、ターゲット統合コンポーネントの論理コンテナーであり、start() および stop() が呼び出されたときに、それらすべてのコンポーネントのライフサイクルを制御します。
このコンポーネントは決して autoStartup ではありません。すべてのコンポーネントがアプリケーションコンテキストで Bean として登録され、それらの最初の起動フェーズはライフサイクルプロセッサーから自動的に制御されるためです。
ただし、IntegrationFlowContext API を使用して IntegrationFlow を動的に登録する場合、アプリケーションコンテキストからのライフサイクルプロセッサーは関与しません。Bean のライフサイクルを手動で制御するか、IntegrationFlowContext API に依存する必要があります。作成された登録 はデフォルトで autoStartup であり、登録時にフローを開始します。登録の自動起動動作を無効にする場合は、フローまたはそのコンポーネント Bean を起動する必要があります。
このコンポーネントは、stop() アクション中に running 状態を追跡せず、登録されたコンポーネントを停止するように直接委譲して、登録された IntegrationFlow がフローコンテキストから削除された後のプロセスのダングリングを回避します。
IntegrationFlows, IntegrationFlowBeanPostProcessor, IntegrationFlowContext, SmartLifecycleDEFAULT_PHASE| 修飾子と型 | メソッドと説明 |
|---|---|
void | configure(IntegrationFlowDefinition<?> flow)EIP メソッドのチェーンを宣言して、提供された IntegrationFlowDefinition との統合フローを構成するためのコールバックベースの関数。 |
MessageChannel | getInputChannel() フロー入力チャネルに不可欠な最初の MessageChannel コンポーネントを返します。 |
MapSE<ObjectSE, StringSE> | getIntegrationComponents() |
int | getPhase() |
boolean | isAutoStartup() |
boolean | isRunning() |
void | setIntegrationComponents(MapSE<ObjectSE, StringSE> integrationComponents) |
void | start() |
void | stop() |
void | stop(RunnableSE callback) |
StringSE | toString() |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSEpublic void configure(IntegrationFlowDefinition<?> flow)
IntegrationFlowIntegrationFlowDefinition との統合フローを構成するためのコールバックベースの関数。IntegrationFlow の configure flow - 構成する IntegrationFlowDefinitionpublic MessageChannel getInputChannel()
IntegrationFlowMessageChannel コンポーネントを返します。IntegrationFlow の getInputChannel public void setIntegrationComponents(MapSE<ObjectSE,StringSE> integrationComponents)
public void stop(RunnableSE callback)
SmartLifecycle の stop public boolean isAutoStartup()
SmartLifecycle の isAutoStartup public int getPhase()
Phased の getPhase SmartLifecycle の getPhase public StringSE toString()
ObjectSE の toStringSE