java - 从死信通道重新传递消息

Question

如果消息重新传递尝试失败，我可以将消息放入死信队列。
如何在死信队列中重新发送存档消息？
Camel 是否为此提供任何解决方案？

Answer 1

正如@sully6768 所建议的那样 - 您可以使用Camel 组件为您处理死消息重新传递（如JMS）。

但是，您还可以定义在 Camel 将消息移动到死信队列之前尝试发送消息的次数（顺便说一句，您还可以定义重新发送尝试之间的时间间隔）。

errorHandler(deadLetterChannel("jms:queue:dead"))
    .maximumRedeliveries(3).redeliveryDelay(5000));

Answer 2

DLQ 只是另一个 JMS 目的地。只需创建一个额外的 Camel 路由，用于处理来自 DLQ 的消息。