delete durable queue (rabbitmq)

以下的 code 可以刪除 queue (include durable queue)

delete_q.py

1 #!/usr/bin/env python
2 # python 2
3 # pika 0.5.2
4 # delete queue (include durable queue)
5 import pika
6 import pickle
7
8 connection = pika.AsyncoreConnection(pika.ConnectionParameters(host='localhost', credentials=pika.PlainCredentials('guest', 'guest')))
9
10 channel = connection.channel()
11 channel.queue_delete(queue='queue-name')
12 channel.close()
13 connection.close()

ref:
http://blog.boxedice.com/2010/10/21/clearing-purging-rabbitmq-queues/