着信ファイルをチャネルに配置するSpringIntegrationアプリがあります。そこから、同じファイルを2つの異なる処理パイプライン(1つはS3にアーカイブし、もう1つはコンテンツを解析する)に送信し、後で両方が正常に処理されたことを認識できるダウンストリームコンポーネントを作成して、実際のローカルファイル。
セマンティクスは、スプリッター/アグリゲーターが必要な場合と似ていますが、メッセージを分割する代わりに、それを複製する必要があります。
利用可能なコンポーネントでこれを実現する方法はありますか、それともいくつかのカスタムクラスが必要ですか?