diff options
| author | Asif Saif Uddin <auvipy@gmail.com> | 2019-06-11 17:49:25 +0600 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-06-11 17:49:25 +0600 |
| commit | fcb8e05cc95bcaf18a23092416f654b88b015163 (patch) | |
| tree | d852e30ccea8ebeff75c704779a4ce9df4e949d3 /kombu/transport/virtual/exchange.py | |
| parent | f9fbd8eb48f21f9e308013209b33758aa5ed47e5 (diff) | |
| download | kombu-fcb8e05cc95bcaf18a23092416f654b88b015163.tar.gz | |
Revert "Use SIMEMBERS instead of SMEMBERS to check for queue (redis broker) (#1041)" (#1058)
This reverts commit 73d2219887dfc5469c0c1ea382baf4749049aef2.
Diffstat (limited to 'kombu/transport/virtual/exchange.py')
| -rw-r--r-- | kombu/transport/virtual/exchange.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kombu/transport/virtual/exchange.py b/kombu/transport/virtual/exchange.py index 4f9e4fb7..51909a1d 100644 --- a/kombu/transport/virtual/exchange.py +++ b/kombu/transport/virtual/exchange.py @@ -65,7 +65,7 @@ class DirectExchange(ExchangeType): } def deliver(self, message, exchange, routing_key, **kwargs): - _lookup = self.channel._lookup_direct + _lookup = self.channel._lookup _put = self.channel._put for queue in _lookup(exchange, routing_key): _put(queue, message, **kwargs) |