从 mule 中的 rabbitmq 队列中恢复消息

Question

我对 Mule ESB 非常陌生。

我创建了一个具有多个队列的流（我使用的是RabbitMQ）。流程有点像一些消息被放入第一个队列，第二个队列将读取该队列将被第三个队列读取，依此类推。

注意：我同时使用JMeter 发送消息。

假设在所有消息可以从第二个队列放入第三个队列之前，我的 rabbitmq 服务器已停止。现在，在这种情况下，我想恢复我的消息。此外，我应该能够知道哪些消息已放入第三个队列以及还剩下哪些消息。

我可能没有以优雅或易于理解的方式提出我的问题，但我希望你能理解我想要实现的目标。

Answer 1

您可以将回滚异常策略 (http://www.mulesoft.org/documentation/display/current/Rollback+Exception+Strategy) 与事务一起使用：http://www.mulesoft.org/documentation/display/current/Transaction+Management 正确实施时，尚未传递到第二个队列的消息将自动回滚。

在回滚异常策略中，您可以编写自定义行为。为什么不使用rabbitmq 客户端查看第三个队列中的哪些消息？