Fix unit test for pika 0.11.0

marionleborgne · Oct 8, 2017 · cf6ec3c · cf6ec3c
1 parent b74c683
commit cf6ec3c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
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/tests/unit/openbci_test.py b/tests/unit/openbci_test.py
@@ -62,7 +62,7 @@ def __init__(self):
         self.message_published = None
 
 
-    def exchange_declare(self, exchange, type):
+    def exchange_declare(self, exchange, exchange_type):
         pass
-Original file line number
+Diff line change
@@ Expand Up / @@ -62,7 +62,7 @@ def __init__(self): @@
             self.message_published = None
-        def exchange_declare(self, exchange, type):
+        def exchange_declare(self, exchange, exchange_type):
             pass
@@ Expand Down @@