mirror of https://github.com/celery/kombu.git
fixed rpc example (#650)
This commit is contained in:
parent
306445f436
commit
32997b17be
|
@ -23,7 +23,7 @@ class FibonacciRpcClient(object):
|
|||
exchange='',
|
||||
routing_key='rpc_queue',
|
||||
declare=[self.callback_queue],
|
||||
reply_to=self.callback_queue,
|
||||
reply_to=self.callback_queue.name,
|
||||
correlation_id=self.correlation_id,
|
||||
)
|
||||
with Consumer(self.connection,
|
||||
|
|
Loading…
Reference in New Issue