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