fixing pika deperecated type

nebula-orchestrator · Sep 18, 2017 · b33dd37 · b33dd37
1 parent 2ae3151
commit b33dd37
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/functions/rabbit_functions.py b/functions/rabbit_functions.py
@@ -23,7 +23,7 @@ def rabbit_create_channel(rabbit_connection):
 
 # create exchange
 def rabbit_create_exchange(rabbit_channel, exchange_name):
-    rabbit_channel.exchange_declare(exchange=exchange_name, type='fanout')
+    rabbit_channel.exchange_declare(exchange=exchange_name, exchange_type='fanout')
     return None