Mule - 错误队列重试队列

Mule - Error queue retry to queue

我在 mule flow 中使用 JMS component (ActiveMQ):

HTTP Listener -> Payload -> JMS (/NormalQueue) -> XSLT -> WS Consumer

我在该流程中有一个 catch-exception strategy,它有一个 JMS 存储消息失败 (/ErrorQueue)

我想做一个停止流默认情况下/ErrorQueue通过Groovy脚本传递给/NormalQueue

我不想使用回滚,因为我需要消息。

如何在队列之间传递消息?或者最好的方法是什么?

执行此操作的最佳方法可能是在您当前的流程之外。为什么不制作一个额外的简单流程,称为 JMSResubmit 之类的东西,它是两个简单的节点,不需要 Groovy 脚本:

JMS Input /ErrorQueue --> JMS Output /NormalQueue

现在任何时候将任何东西放到 /ErrorQueue 上,它都会被发送回 /NormalQueue