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
我在 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