清除 mule 3 中 rabbitMQ 队列中的消息

clear messages from rabbitMQ queue in mule 3

我的要求是在处理流或在队列中发布任何内容之前清除队列中的所有消息。 我们正在使用 rabbitMQ,由于某些原因消息被卡在队列中,因此我们在根据消息对队列进行计数时遇到了一些问题。所以在下一次处理之前我们必须清除队列。 这里我们有多个队列,如 slave1、slave2、slave3,当 api 将在进程部分被触发时,我们必须清除队列。

请建议我们如何在 mule3 中执行此操作。

Mule 3 有一个通用的 AMQP 连接器。它不支持来自 RabbitMQ 等特定实现的管理命令,因此您不能使用该连接器。

您可以使用 RabbitMQ REST API 并使用 HTTP 请求连接器调用它。请参阅之前的答案以了解如何使用 Curl 删除队列,然后使用 HTTP 请求实现相同的请求: