diff options
| author | Chris Lambacher <clambacher@heroku.com> | 2020-09-30 17:00:13 -0400 |
|---|---|---|
| committer | Asif Saif Uddin <auvipy@gmail.com> | 2020-10-13 10:38:43 +0600 |
| commit | bcf0ffe772dbfe8113e20646b0d9266d83f06639 (patch) | |
| tree | e64736752aad2cc2663d5da0e2b1b884231c699f | |
| parent | b79146d8a1f822c486f6ab0df8bf36b5c53cf70d (diff) | |
| download | kombu-bcf0ffe772dbfe8113e20646b0d9266d83f06639.tar.gz | |
Fix pidbox not using default channels
Not all cases are properly using the default channel even when detecting
for it.
Fixes: #1201
| -rw-r--r-- | kombu/pidbox.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kombu/pidbox.py b/kombu/pidbox.py index 85fee756..c8179a53 100644 --- a/kombu/pidbox.py +++ b/kombu/pidbox.py @@ -297,7 +297,7 @@ class Mailbox: chan = channel or self.connection.default_channel exchange = self.exchange if reply_ticket: - maybe_declare(self.reply_queue(channel)) + maybe_declare(self.reply_queue(chan)) message.update(ticket=reply_ticket, reply_to={'exchange': self.reply_exchange.name, 'routing_key': self.oid}) @@ -356,7 +356,7 @@ class Mailbox: accept = self.accept chan = channel or self.connection.default_channel queue = self.reply_queue - consumer = Consumer(channel, [queue], accept=accept, no_ack=True) + consumer = Consumer(chan, [queue], accept=accept, no_ack=True) responses = [] unclaimed = self.unclaimed adjust_clock = self.clock.adjust |