Empty existing RabbitMQ Queue

emptyrmq.py

import pika, json

# Clear the RMQ
def callback(ch, method, properties, body):
    pass

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='Phantom')
channel.basic_consume(callback, queue='Phantom', no_ack=True)
connection.close()