Ich möchte alle Nachrichten aus der Hase-mq-Warteschlange löschen, bevor ich anfange, Daten in sie zu schieben. Wie kann dies erreicht werden? Ich verwende https://www.npmjs.com/package/amqplibWie lösche ich alle Nachrichten von rabbitmq mit Hilfe der Knotenbibliothek?
1
A
Antwort
2
gibt es eine purgeQueue
Methode: http://www.squaremobius.net/amqp.node/channel_api.html#channel_purgeQueue
channel.purgeQueue("some.queue");
0
purge_queue kann verwendet werden, um alle nicht zugestellten Nachrichten aus der Warteschlange namens zu entfernen.
purgeQueue(queue, [function(err, ok) {...}])
Entferne alle nicht zugestellten Nachrichten aus der Warteschlange named.messageCount, aus der Warteschlange gelöscht wird, um die Anzahl von Nachrichten enthält, zurückgeführt.
Sie können auch diese mithilfe von Befehlszeilen tun:
sudo rabbitmqctl purge_queue queue_name