使用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属性将异常（包含标题中的错误信息）发送到死信队列;您可以从该队列中消耗。