我有一个兔子队列,其中包含待消费的消息。我还有一个可能失败的监听器。该队列配置了死信交换(以及死信队列)。我想要的是在死信队列中看到消息中的异常信息。
目前的工作方式如下:
例如,在我的监听器中放置通用try-catch并增强标题以包含异常信息是否可行?
目前的工作方式如下:
- 我向我的正常队列发送一条损坏的消息。
- 我的监听器(我使用Java的org.springframework.amqp.core.MessageListener)失败,并显示类似于:“java.lang.RuntimeException:corrupted message”的内容。
- 该消息被拒绝并通过死信交换进入死信队列。
- 当我查看Rabbit管理界面中的死信消息时,我看到:
headers:
x-death:
reason: rejected
例如,在我的监听器中放置通用try-catch并增强标题以包含异常信息是否可行?