Merge pull request rabbitmq#225 from rabbitmq/rabbitmq-website-780

Explicitly use queue parameter name
beiluoL · Jun 7, 2019 · b887f23 · b887f23
2 parents a814c87 + ea20da7
commit b887f23
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/python/receive_logs.py b/python/receive_logs.py
@@ -7,7 +7,7 @@
 
 channel.exchange_declare(exchange='logs', exchange_type='fanout')
 
-result = channel.queue_declare('', exclusive=True)
+result = channel.queue_declare(queue='', exclusive=True)
 queue_name = result.method.queue
 
 channel.queue_bind(exchange='logs', queue=queue_name)

diff --git a/python/receive_logs_direct.py b/python/receive_logs_direct.py
@@ -8,7 +8,7 @@
 
 channel.exchange_declare(exchange='direct_logs', exchange_type='direct')
 
-result = channel.queue_declare('', exclusive=True)
+result = channel.queue_declare(queue='', exclusive=True)
 queue_name = result.method.queue
 
 severities = sys.argv[1:]

diff --git a/python/receive_logs_topic.py b/python/receive_logs_topic.py
@@ -8,7 +8,7 @@
 
 channel.exchange_declare(exchange='topic_logs', exchange_type='topic')
 
-result = channel.queue_declare('', exclusive=True)
+result = channel.queue_declare(queue='', exclusive=True)
 queue_name = result.method.queue
 
 binding_keys = sys.argv[1:]

diff --git a/python/rpc_client.py b/python/rpc_client.py
@@ -11,7 +11,7 @@ def __init__(self):
 
         self.channel = self.connection.channel()
 
-        result = self.channel.queue_declare('', exclusive=True)
+        result = self.channel.queue_declare(queue='', exclusive=True)
         self.callback_queue = result.method.queue
 
         self.channel.basic_consume(