diff --git a/notifications b/notifications
--- a/notifications
+++ b/notifications
@@ -62,7 +62,7 @@
     """Ensure exchange exists and declare a temporary queue."""
     channel.exchange_declare(
         exchange=exchange, exchange_type='topic', durable=True)
-    result = channel.queue_declare(exclusive=True)
+    result = channel.queue_declare("", exclusive=True)
     return result.method.queue
 
 
@@ -190,7 +190,7 @@
     """Consume notifications from a queue
     and call our callback method when a message is received.
     """
-    channel.basic_consume(on_broker_message, queue=queue)
+    channel.basic_consume(queue, on_broker_message)
     channel.start_consuming()
 
 
diff --git a/requirements.txt b/requirements.txt
new file mode 100644
--- /dev/null
+++ b/requirements.txt
@@ -0,0 +1 @@
+pika<2.0.0,>=1.1.0