Rooba
/
kombu
mirror of https://github.com/celery/kombu.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix pidbox not using default channels 

Not all cases are properly using the default channel even when detecting
for it.

Fixes: #1201
This commit is contained in:
Chris Lambacher 2020-09-30 17:00:13 -04:00 committed by Asif Saif Uddin
parent b79146d8a1
commit bcf0ffe772
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
kombu/pidbox.py
View File

@ -297,7 +297,7 @@ class Mailbox:
chan = channel or self.connection.default_channel chan = channel or self.connection.default_channel
exchange = self.exchange exchange = self.exchange
if reply_ticket: if reply_ticket:
maybe_declare(self.reply_queue(channel)) maybe_declare(self.reply_queue(chan))
message.update(ticket=reply_ticket, message.update(ticket=reply_ticket,
reply_to={'exchange': self.reply_exchange.name, reply_to={'exchange': self.reply_exchange.name,
'routing_key': self.oid}) 'routing_key': self.oid})
@ -356,7 +356,7 @@ class Mailbox:
accept = self.accept accept = self.accept
chan = channel or self.connection.default_channel chan = channel or self.connection.default_channel
queue = self.reply_queue queue = self.reply_queue
consumer = Consumer(channel, [queue], accept=accept, no_ack=True) consumer = Consumer(chan, [queue], accept=accept, no_ack=True)
responses = [] responses = []
unclaimed = self.unclaimed unclaimed = self.unclaimed
adjust_clock = self.clock.adjust adjust_clock = self.clock.adjust