mirror of https://github.com/celery/kombu.git
pidbox: Declare reply exchange when sending reply
This commit is contained in:
parent
dfa1b37fac
commit
12808079ba
|
@ -182,7 +182,7 @@ class Mailbox(object):
|
|||
durable=False,
|
||||
auto_delete=True)
|
||||
producer = Producer(chan, exchange=exchange,
|
||||
auto_declare=False)
|
||||
auto_declare=True)
|
||||
producer.publish(reply, routing_key=routing_key)
|
||||
finally:
|
||||
channel or chan.close()
|
||||
|
|
Loading…
Reference in New Issue