Skip to content

Instantly share code, notes, and snippets.

@dickbrouwer

dickbrouwer/clear_amqp-queue.py

Created August 24, 2012 00:03
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save dickbrouwer/3443798 to your computer and use it in GitHub Desktop.
Save dickbrouwer/3443798 to your computer and use it in GitHub Desktop.
Download ZIP
Clearing AMQP queue
Raw
clear_amqp-queue.py
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>")
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment