diff --git a/kombu/transport/redis.py b/kombu/transport/redis.py index 48e01a831..552e680e7 100644 --- a/kombu/transport/redis.py +++ b/kombu/transport/redis.py @@ -1087,12 +1087,13 @@ def _purge(self, queue): def close(self): self._closing = True - if self._in_poll: - try: - self._brpop_read() - except Empty: - pass if not self.closed: + if self._in_poll: + try: + self._brpop_read() + except Empty: + pass + # remove from channel poller. self.connection.cycle.discard(self)