moops

2014-08-19 22:47:33 -07:00
parent 3af61b06b1
commit 8b6c3bb684
1 changed files with 1 additions and 0 deletions
--- a/test.py
+++ b/test.py
@@ -40,6 +40,7 @@ def consume(request, params):

    cxn = pika.BlockingConnection(params)
    channel = cxn.channel()
+    channel.queue_declare(queue='pika_pool_test')
    channel.basic_consume(_callback, queue='pika_pool_test', no_ack=True)

    threading.Thread(target=_forever).start()