Spring Cloud StreamとRabbitMqでの例外処理

Question

Spring Cloud Streamでの例外処理に関する情報の検索に問題があります。私は、例外を処理すると思われるerrorChannelがあることを知っていますが、私はそれをどのように使用するか考えていません。誰も私にサンプルを与えることができますか？現在、シンク（@StreamListener(target = Sink.SAMPLE)）にイベントを送信し、処理中にMessageHandlingExceptionが発生すると、ログのみが取得され、ソースに通知するメカニズムはありません。私は@ControllerAdvice in my sink applicationを使用して古典的なSpring MVCスタイルで例外をキャッチしようとしましたが、どうしたらいいかとは思いません。

Answer 1

バインダーは、現在、エラーチャネルにパブリッシュされません。我々は次のリリースのためにそれを修正しているので、あなたはアプリで例外を消費することができます。

現在、autoBindDlqおよびrepublishToDlqプロパティを使用して、ヘッダーにエラー情報を含む例外をデッドレターキューに送信できます。そのキューから消費することができます。