node.js - 如何使用 Node 库从rabbitmq删除所有消息？

我想先删除Rabbit MQ队列中的所有消息，然后再开始向其中推送数据。如何实现呢？我正在使用https://www.npmjs.com/package/amqplib

最佳答案

有一个purgeQueue方法：http://www.squaremobius.net/amqp.node/channel_api.html#channel_purgeQueue

channel.purgeQueue("some.queue");