Suppression de files d'attente dans rabbitmq

Question

J'ai quelques files d'attente sous RabbitMq. Quelques-uns d'entre eux ne sont d'aucune utilité, comment puis-je les supprimer? Malheureusement, je n'avais pas défini l'option auto_delete.

Si je le configure maintenant, sera-t-il supprimé?

Est-il possible de supprimer ces files d'attente maintenant?

Merci!

Answer 1

Si vous n'avez pas de soins sur les autres files d'attente, vous pouvez supprimer tous les de via ligne de commande en exécutant les commandes suivantes dans l'ordre:

Avertissement: cela permettra également de supprimer les utilisateurs et les vhosts vous avez configuré sur votre serveur de lapin

rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl start_app

Le rabbitmq documentation dit que l' reset commande:

Supprime le nœud à partir de n'importe quel groupe il appartient, supprime toutes les données de la gestion de la base de données, tels que les utilisateurs configurés et vhosts, et supprime tous les messages persistants.

Donc, veillez à l'utiliser.

Answer 2

 import pika

connection = pika.BlockingConnection(pika.ConnectionParameters(
               'localhost'))
channel = connection.channel()

channel.queue_delete(queue='queue-name')

connection.close()
 

Installez le paquet pika comme suit

 $ sudo pip install pika==0.9.8
 

L'installation dépend des paquets pip et git-core, vous devrez peut-être les installer d'abord.

Sur Ubuntu:

 $ sudo apt-get install python-pip git-core
 

Sur Debian:

 $ sudo apt-get install python-setuptools git-core
$ sudo easy_install pip
 

Sous Windows: pour installer easy_install, lancez MS Windows Installer pour setuptools.

 > easy_install pip
> pip install pika==0.9.8
 

Answer 3

Dans les versions de RabbitMQ> 3.0, vous pouvez également utiliser l'API HTTP si le plug-in rabbitmq_management est activé. Assurez-vous simplement de définir le type de contenu sur 'application / json' et de fournir le nom vhost et le nom de la file d'attente:

IE Utilisation de curl avec un 'test' vhost et un nom de file d'attente 'testqueue':

 $ curl -i -u guest:guest -H "content-type:application/json" -XDELETE http://localhost:15672/api/queues/test/testqueue
HTTP/1.1 204 No Content
Server: MochiWeb/1.1 WebMachine/1.9.0 (someone had painted it blue)
Date: Tue, 16 Apr 2013 10:37:48 GMT
Content-Type: application/json
Content-Length: 0
 

Answer 4

Vous affirmer qu'une file d'attente existe (et de la créer si elle n'a pas) à l'aide de la file d'attente.déclarer. Si défini à l'origine, l'auto-supprimer pour de faux, l'appel de la file d'attente.déclarer à nouveau avec la commande autodelete vrai entraînera une erreur logicielle et le courtier va fermer le canal.

Vous avez besoin d'utiliser la file d'attente.supprimer maintenant afin de le supprimer.

Voir la documentation de l'API pour plus de détails:

• Client Java queueDelete
• .NET Client queueDelete

Si vous utilisez un autre client, vous aurez besoin de trouver l'équivalent de la méthode. Comme il fait partie du protocole, il devrait être là, et c'est probablement la partie de Canal ou l'équivalent.

Vous pouvez également avoir un regard sur le reste de la documentation, en particulier les Geting Commencé section qui couvre beaucoup de cas d'utilisation courants.

Enfin, si vous avez une question et ne peut pas trouver la réponse ailleurs, vous devriez essayer de poster sur le RabbitMQ Discuter de la liste de diffusion. Les développeurs font de leur mieux pour répondre à toutes les questions posées.

Answer 5

Une autre option serait d’activer le management_plugin et de vous y connecter via un navigateur. Vous pouvez voir toutes les files d'attente et les informations les concernant. Il est possible et simple de supprimer des files d'attente de cette interface.