From 8b6c3bb68431cc9f441d6d2dee040de51d33d60c Mon Sep 17 00:00:00 2001 From: bninja Date: Tue, 19 Aug 2014 22:47:33 -0700 Subject: [PATCH] moops --- test.py | 1 + 1 file changed, 1 insertion(+) diff --git a/test.py b/test.py index eac8fa6..4739455 100644 --- 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()