diff options
author | Asif Saif Uddin <auvipy@gmail.com> | 2019-11-08 11:47:07 +0600 |
---|---|---|
committer | GitHub <noreply@github.com> | 2019-11-08 11:47:07 +0600 |
commit | e7d9fe4513e4ea48d1fb86e8194336748e1aa63a (patch) | |
tree | 9cf0ec88bec7da2eb3387fb27763d47f62ed0354 | |
parent | 597d675ca15260794308be5b9641ea7fde9404f4 (diff) | |
download | kombu-revert-1068-revert-1058-revert-1041-master.tar.gz |
Revert "Revert "Revert "Use SIMEMBERS instead of SMEMBERS to check for queue (redis broker) (#1041)" (#1058)" (#1068)"revert-1068-revert-1058-revert-1041-master
This reverts commit 052f7601d3a1e09263cc0ebda7ef8c16e6b90175.
-rw-r--r-- | kombu/transport/redis.py | 18 | ||||
-rw-r--r-- | kombu/transport/virtual/base.py | 16 | ||||
-rw-r--r-- | kombu/transport/virtual/exchange.py | 2 | ||||
-rw-r--r-- | t/unit/transport/test_redis.py | 3 |
4 files changed, 1 insertions, 38 deletions
diff --git a/kombu/transport/redis.py b/kombu/transport/redis.py index 6dce7443..9348a1ba 100644 --- a/kombu/transport/redis.py +++ b/kombu/transport/redis.py @@ -836,24 +836,6 @@ class Channel(virtual.Channel): raise InconsistencyError(NO_ROUTE_ERROR.format(exchange, key)) return [tuple(bytes_to_str(val).split(self.sep)) for val in values] - def _lookup_direct(self, exchange, routing_key): - if not exchange: - return [routing_key] - - key = self.keyprefix_queue % exchange - pattern = '' - queue = routing_key - queue_bind = self.sep.join([ - routing_key or '', - pattern, - queue or '', - ]) - with self.conn_or_acquire() as client: - if client.sismember(key, queue_bind): - return [queue] - - return [] - def _purge(self, queue): with self.conn_or_acquire() as client: with client.pipeline() as pipe: diff --git a/kombu/transport/virtual/base.py b/kombu/transport/virtual/base.py index 9450cad2..61ede626 100644 --- a/kombu/transport/virtual/base.py +++ b/kombu/transport/virtual/base.py @@ -725,22 +725,6 @@ class Channel(AbstractChannel, base.StdChannel): R = [default] return R - def _lookup_direct(self, exchange, routing_key): - """Find queue matching `routing_key` for given direct `exchange`. - - Returns: - str: queue name - """ - if not exchange: - return [routing_key] - - return self.exchange_types['direct'].lookup( - table=self.get_table(exchange), - exchange=exchange, - routing_key=routing_key, - default=None, - ) - def _restore(self, message): """Redeliver message to its original destination.""" delivery_info = message.delivery_info 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) diff --git a/t/unit/transport/test_redis.py b/t/unit/transport/test_redis.py index 33b01fa0..58e22413 100644 --- a/t/unit/transport/test_redis.py +++ b/t/unit/transport/test_redis.py @@ -88,9 +88,6 @@ class Client(object): def smembers(self, key): return self.sets.get(key, set()) - def sismember(self, name, value): - return value in self.sets.get(name, set()) - def ping(self, *args, **kwargs): return True |