使用 Spring Cloud Stream 和 RabbitMq 进行异常处理
Exception handling with Spring Cloud Stream and RabbitMq
我在 Spring Cloud Stream 中查找有关异常处理的任何信息时遇到问题。我知道有 errorChannel 可以处理异常，但我不知道如何使用它。谁能给我任何样品？目前，当我向我的接收器 (@StreamListener(target = Sink.SAMPLE)) 发送事件并且在处理过程中 MessageHandlingException 将发生时，我只获取日志并且没有机制通知我的源。我尝试使用 @ControllerAdvice in my sink application 并以经典 Spring MVC 风格捕获异常，但我不认为它应该如何完成。
活页夹目前没有发布到错误通道；我们正在为下一个版本对其进行修改，以便您能够在应用程序中使用异常。
目前，您可以使用autoBindDlq和republishToDlq属性将异常（错误信息在headers中）发送到死信queue；然后你可以从中消费 queue.
我在 Spring Cloud Stream 中查找有关异常处理的任何信息时遇到问题。我知道有 errorChannel 可以处理异常，但我不知道如何使用它。谁能给我任何样品？目前，当我向我的接收器 (@StreamListener(target = Sink.SAMPLE)) 发送事件并且在处理过程中 MessageHandlingException 将发生时，我只获取日志并且没有机制通知我的源。我尝试使用 @ControllerAdvice in my sink application 并以经典 Spring MVC 风格捕获异常，但我不认为它应该如何完成。
活页夹目前没有发布到错误通道；我们正在为下一个版本对其进行修改，以便您能够在应用程序中使用异常。
目前，您可以使用autoBindDlq和republishToDlq属性将异常（错误信息在headers中）发送到死信queue；然后你可以从中消费 queue.