アウトバウンドアダプターの直前にアグリゲーターがあります (リクエストをバッチ処理するため)。
アウトバウンド アダプターに障害が発生した場合、アグリゲーターがメッセージのリリースを停止し、最終的にアウトバウンド アダプターがオンラインに戻るまで、背圧が統合フローに伝播するようにしたいと考えています。
これは、EIP 内で望ましいパターンであるように思われます。これには、キューに基づくチャネルが含まれていることは確かですが、いくつかの理由から、これがどのように実装されているかはわかりません。
A) アダプターの失敗の開始が例外によって暗示されている場合 (実際@retryable、送信アダプターで使用しています)、メッセージを再キューイングする「正しい」方法は何ですか?
B)アグリゲータのリーパー スレッドがダウンストリーム キューの「背圧」を尊重すると仮定しています。とはいえ、そのような状況でアグリゲーターにアップストリームからのメッセージの消費を停止するように指示するにはどうすればよいでしょうか?