我有一个兔子队列,里面有消费消息。我也有一个可能会失败的听众。该队列配置有死信交换(连同死信队列)。我想要的是在死信队列中的消息中查看异常信息。
以下是它目前的工作方式:
- 我将损坏的消息发送到我的正常队列。
- 我的监听器(我正在使用 Java 的 org.springframework.amqp.core.MessageListener)失败并出现类似:“java.lang.RuntimeException:消息损坏”
- 消息被拒绝并通过死信交换进入死信队列。
- 当我在 Rabbit Admin UI 中查看死信消息时,我看到: headers:
x-death:
reason: denied
但我想要的是在 UI 的某处看到“java.lang.RuntimeException:损坏的消息”。我认为它应该是一个自定义标题?
例如,是否可以为我的侦听器放置一个通用的 try-catch 并使用异常信息增强标头?