FIX: publisher args

marionleborgne · Oct 8, 2017 · 475537a · 475537a
1 parent 9096938
commit 475537a
Showing 1 changed file with 1 addition and 1 deletion.
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, exchange_type='direct')
+        channel.exchange_declare(exchange=routing_key, type='direct')
         self.channels[routing_key] = channel
 
     def publish(self, metric_name, data):