Merge pull request rabbitmq#100 from Mandar12/master

michaelklishin · web-flow · commit 083b214459d4 · 2016-09-06T14:01:01.000+04:00
Fix: deprecation warning for type
diff --git a/python/emit_log.py b/python/emit_log.py
@@ -7,7 +7,7 @@
 channel = connection.channel()
 
 channel.exchange_declare(exchange='logs',
-                         type='fanout')
+                         exchange_type='fanout')
 
 message = ' '.join(sys.argv[1:]) or "info: Hello World!"
 channel.basic_publish(exchange='logs',
diff --git a/python/emit_log_direct.py b/python/emit_log_direct.py
@@ -7,7 +7,7 @@
 channel = connection.channel()
 
 channel.exchange_declare(exchange='direct_logs',
-                         type='direct')
+                         exchange_type='direct')
 
 severity = sys.argv[1] if len(sys.argv) > 1 else 'info'
 message = ' '.join(sys.argv[2:]) or 'Hello World!'
diff --git a/python/emit_log_topic.py b/python/emit_log_topic.py
@@ -7,7 +7,7 @@
 channel = connection.channel()
 
 channel.exchange_declare(exchange='topic_logs',
-                         type='topic')
+                         exchange_type='topic')
 
 routing_key = sys.argv[1] if len(sys.argv) > 1 else 'anonymous.info'
 message = ' '.join(sys.argv[2:]) or 'Hello World!'
diff --git a/python/receive_logs.py b/python/receive_logs.py
@@ -6,7 +6,7 @@
 channel = connection.channel()
 
 channel.exchange_declare(exchange='logs',
-                         type='fanout')
+                         exchange_type='fanout')
 
 result = channel.queue_declare(exclusive=True)
 queue_name = result.method.queue
diff --git a/python/receive_logs_direct.py b/python/receive_logs_direct.py
@@ -7,7 +7,7 @@
 channel = connection.channel()
 
 channel.exchange_declare(exchange='direct_logs',
-                         type='direct')
+                         exchange_type='direct')
 
 result = channel.queue_declare(exclusive=True)
 queue_name = result.method.queue
diff --git a/python/receive_logs_topic.py b/python/receive_logs_topic.py
@@ -7,7 +7,7 @@
 channel = connection.channel()
 
 channel.exchange_declare(exchange='topic_logs',
-                         type='topic')
+                         exchange_type='topic')
 
 result = channel.queue_declare(exclusive=True)
 queue_name = result.method.queue
