echo/rabbitmq-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #100 from Mandar12/master

Browse Source 
Fix: deprecation warning for type
This commit is contained in:
Michael Klishin 2016-09-06 14:01:01 +04:00 committed by GitHub
commit 083b214459
6 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
python/emit_log.py
View File

@ -7,7 +7,7 @@ connection = pika.BlockingConnection(pika.ConnectionParameters(
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',

2
python/emit_log_direct.py
View File

@ -7,7 +7,7 @@ connection = pika.BlockingConnection(pika.ConnectionParameters(
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!'

2
python/emit_log_topic.py
View File

@ -7,7 +7,7 @@ connection = pika.BlockingConnection(pika.ConnectionParameters(
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!'

2
python/receive_logs.py
View File

@ -6,7 +6,7 @@ connection = pika.BlockingConnection(pika.ConnectionParameters(
channel = connection.channel()
channel.exchange_declare(exchange='logs',
type='fanout')
exchange_type='fanout')
result = channel.queue_declare(exclusive=True)
queue_name = result.method.queue

2
python/receive_logs_direct.py
View File

@ -7,7 +7,7 @@ connection = pika.BlockingConnection(pika.ConnectionParameters(
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

2
python/receive_logs_topic.py
View File

@ -7,7 +7,7 @@ connection = pika.BlockingConnection(pika.ConnectionParameters(
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