bump up pika version

marionleborgne · Oct 8, 2017 · 9096938 · 9096938
1 parent d14dc8a
commit 9096938
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/requirements/core.txt b/requirements/core.txt
@@ -1,4 +1,4 @@
 simplejson==3.8.2
-pika==0.10
+pika==0.11.0
 requests[security]==2.18.1
 pyserial==2.7
diff --git a/src/cloudbrain/publishers/rabbitmq.py b/src/cloudbrain/publishers/rabbitmq.py
@@ -61,7 +61,7 @@ def register(self, metric_name, num_channels, buffer_size=1):
 
     def _rabbitmq_register(self, routing_key):
         channel = self.connection.channel()
-        channel.exchange_declare(exchange=routing_key, type='direct')
+        channel.exchange_declare(exchange=routing_key, exchange_type='direct')
         self.channels[routing_key] = channel
 
     def publish(self, metric_name, data):

diff --git a/src/cloudbrain/subscribers/rabbitmq.py b/src/cloudbrain/subscribers/rabbitmq.py
@@ -49,7 +49,7 @@ def register(self, metric_name, num_channels, buffer_size=1):
 
     def _rabbitmq_register(self, routing_key):
         channel = self.connection.channel()
-        channel.exchange_declare(exchange=routing_key, type='direct')
+        channel.exchange_declare(exchange=routing_key, exchange_type='direct')
 
         queue_name = channel.queue_declare(exclusive=True).method.queue
         channel.queue_bind(exchange=routing_key,