We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 72daf5c commit d87f64cCopy full SHA for d87f64c
python/rpc_client.py
@@ -5,11 +5,11 @@
5
class FibonacciClient(object):
6
def __init__(self):
7
self.connection = pika.AsyncoreConnection(pika.ConnectionParameters(
8
- host='127.0.0.1',
9
- credentials=pika.PlainCredentials('guest', 'guest')))
+ host='localhost'))
+
10
self.channel = self.connection.channel()
11
12
- result = self.channel.queue_declare(auto_delete=True)
+ result = self.channel.queue_declare(exclusive=True)
13
self.callback_queue = result.queue
14
15
self.requests = {}
python/rpc_server.py
@@ -3,8 +3,8 @@
3
4
connection = pika.AsyncoreConnection(pika.ConnectionParameters(
channel = connection.channel()
0 commit comments