Purging an AMQP queue
Clearing a RabbitMQ (AMQP) queue is not as straightforward as it should be. Python’s amqplib makes this a bit easier:
from amqplib import client_0_8 as amqp
conn = amqp.Connection(host="localhost:5672", userid="<user>", password="<passwd>", virtual_host="<vhost>", insist=False)
conn = conn.channel()
conn.queue_purge("<queue_name>")
