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
, SmartLifecycle
DEFAULT_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, waitSE
public void configure(IntegrationFlowDefinition<?> flow)
IntegrationFlow
IntegrationFlowDefinition
との統合フローを構成するためのコールバックベースの関数。IntegrationFlow
の configure
flow
- 構成する IntegrationFlowDefinition
public MessageChannel getInputChannel()
IntegrationFlow
MessageChannel
コンポーネントを返します。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