Fix: deprecation warning for type in exchange_declare

Author: Mandar12

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',

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!'

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!'

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

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

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