diff --git a/kombu/transport/pyredis.py b/kombu/transport/pyredis.py index e5f95c27..66234220 100644 --- a/kombu/transport/pyredis.py +++ b/kombu/transport/pyredis.py @@ -178,7 +178,7 @@ class Channel(virtual.Channel): except self.connection.connection_errors: self._in_listen = False if response is not None: - payload = self._handle_message(client, response) + payload = self._handle_message(c, response) if payload["type"] == "message": return (deserialize(payload["data"]), self._fanout_to_queue[payload["channel"]])