1 2 3 4 5 6 7 8 9 10 11 12 |
import pika import atexit import sys if len(sys.argv) < 2: print 'usage:', sys.argv[0], '<queue>' sys.exit(1) host = '10.55.60.168' conn = pika.BlockingConnection(pika.ConnectionParameters(host)) atexit.register(conn.close) channel = conn.channel() channel.queue_purge(queue=sys.argv[1]) |