From cf6ec3ccde9b8d06a672a1b1bfa9420022ad872f Mon Sep 17 00:00:00 2001 From: Marion Le Borgne Date: Sun, 8 Oct 2017 00:54:09 -0700 Subject: [PATCH] Fix unit test for pika 0.11.0 --- src/cloudbrain/publishers/rabbitmq.py | 2 +- tests/unit/openbci_test.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/cloudbrain/publishers/rabbitmq.py b/src/cloudbrain/publishers/rabbitmq.py index e44a99f..62432c2 100644 --- 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 index ac63b11..a3d884e 100644 --- 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