死信时如何在兔子消息上指定附加信息

Question

我有一个兔子队列，里面有消息供消费。我也有一个可能会失败的听众。该队列配置有死信交换（连同死信队列）。我想要的是在死信队列中的消息中查看异常信息。

这是它目前的工作方式：

1. 我将损坏的消息发送到我的正常队列。
2. 我的侦听器（我正在使用 Java 的 org.springframework.amqp.core.MessageListener）失败，并显示如下内容：“java.lang.RuntimeException: 已损坏消息”
3. 消息被拒绝并通过死信交换进入死信队列。
4. 当我查看 Rabbit 管理 UI 中的死信消息时，我看到： 标题：
   x-死亡：
   原因：拒绝

但我想要的是在 UI 的某处看到“java.lang.RuntimeException：损坏的消息”。我认为它应该是一个自定义标题？

例如，是否可以为我的侦听器添加一个通用的 try-catch 并使用异常信息增强标头？

Answer 1

没有； RabbitMQ（实际上是 AMQP 规范）没有为消费者提供使用附加信息来增强被拒绝消息的机制。该协议仅支持确认或拒绝消息。

Spring AMQP 与重试拦截器一起提供了一种将消息重新发布到不同队列（可以与 DLQ 相同）的机制，并在标头中包含附加信息（异常堆栈跟踪等）。

见RepublishMessageRecoverer in the section about error handling with asynchronous consumers。