清除 mule 3 中的rabbitMQ队列中的消息
我的要求是在处理流程或发布队列中的任何内容之前清除队列中的所有消息。 我们正在使用rabbitMQ，由于某种原因，消息被困在队列中，因此，当我们根据消息对队列进行计数时，我们遇到了一些问题。因此，在下次处理之前，我们必须清除队列。 这里我们有多个队列，如slave1、slave2、slave3，当api在进程部分被触发时，我们必须清除队列。
请建议我们如何在 mule3 中做到这一点。 
My requirement is to clear all the messages from queue before processing the flow or publishing anything in the queue.
We are using rabbitMQ and due to some reason messages are stucked in the queue and because of that we are facing some issue when we are counting the queue based on the messages. so for the next time before processing we have to clear the queue.
Here we have multiple queue like slave1, slave2,slave3 and when api will be triggered in the process section we have to clear the queue.
Kindly suggest how we can do this in mule3.
如果你对这篇内容有疑问，欢迎到本站社区发帖提问 参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱，如果其他用户或者作者回复了您的评论，将不能在第一时间通知您！
发布评论
评论（1）
Mule 3 有一个通用的 AMQP 连接器。它不支持来自 RabbitMQ 等特定实现的管理命令，因此您无法使用连接器。
您可以使用 RabbitMQ REST API 并使用 HTTP 请求连接器调用它。请参阅之前的答案，了解如何使用 Curl 删除队列，然后使用 HTTP 请求实现相同的请求：https://stackoverflow.com/ a/29148299/721855
Mule 3 has a generic AMQP connector. It does not support administrative commands from a specific implementation like RabbitMQ, so you can't use the connector.
You could use RabbitMQ REST API and call it using the HTTP Request connector. See this previous answer to see how to delete queues with Curl, then implement the same request with HTTP Request: https://stackoverflow.com/a/29148299/721855