正常なシャットダウン

"MBean エクスポーター" に従って、MBean エクスポーターは stopActiveComponents と呼ばれる JMX 操作を提供します。これは、アプリケーションを正常に停止するために使用されます。操作には単一の Long パラメーターがあります。このパラメーターは、処理中のメッセージの補完を待機する時間（ミリ秒単位）を示します。操作は次のように機能します。

  1. OrderlyShutdownCapable を実装するすべての Bean で beforeShutdown() を呼び出します。

    そうすることで、そのようなコンポーネントはシャットダウンの準備ができます。このインターフェースを実装するコンポーネントの例と、この呼び出しで行うことには、リスナーコンテナーを停止する JMS および AMQP メッセージ駆動型アダプター、新しい接続の受け入れを停止する（既存の接続を開いたまま）TCP サーバー接続ファクトリ、ドロップする TCP 受信エンドポイントが含まれます（ログ）受信した新しいメッセージ、新しいリクエストに対して 503 - Service Unavailable を返す HTTP 受信エンドポイント。

  2. JMS または AMQP-backed チャネルなどのアクティブなチャネルを停止します。

  3. すべての MessageSource インスタンスを停止します。

  4. すべての受信 MessageProducer を停止します（OrderlyShutdownCapable ではありません）。

  5. 操作に渡される Long パラメーターの値で定義されているように、残り時間が残っているのを待ちます。

    そうすることで、飛行中のメッセージがすべての旅を完了することができます。この操作を呼び出すときに適切なタイムアウトを選択することが重要です。

  6. すべての OrderlyShutdownCapable コンポーネントで afterShutdown() を呼び出します。

    これにより、そのようなコンポーネントは最終的なシャットダウンタスクを実行できます（たとえば、開いているすべてのソケットを閉じる）。

正常なシャットダウン管理操作で説明したように、この操作は JMX を使用して呼び出すことができます。プログラムでメソッドを呼び出す場合は、IntegrationMBeanExporter への参照を挿入するか、取得する必要があります。id 属性が <int-jmx:mbean-export/> 定義で指定されていない場合、Bean には名前が生成されます。この名前には、同じ JVM（MBeanServer）に複数の Spring Integration コンテキストが存在する場合に ObjectName の衝突を回避するためのランダムなコンポーネントが含まれています。

このため、プログラムでメソッドを呼び出す場合は、アプリケーションコンテキストで簡単にアクセスできるように、エクスポーターに id 属性を提供することをお勧めします。

最後に、<control-bus> 要素を使用して操作を呼び出すことができます。詳細については、モニタリング Spring Integration サンプルアプリケーション [GitHub] (英語) を参照してください。

前述のアルゴリズムは、バージョン 4.1 で改善されました。以前は、すべてのタスクエグゼキューターとスケジューラーが停止していました。これにより、QueueChannel インスタンスの中間フローメッセージが残る可能性があります。これで、シャットダウンによりポーラーが実行されたままになり、これらのメッセージを排出して処理できるようになります。