diff options
| author | Ask Solem <ask@celeryproject.org> | 2013-11-22 10:45:47 +0000 |
|---|---|---|
| committer | Ask Solem <ask@celeryproject.org> | 2013-11-22 10:45:47 +0000 |
| commit | 8786acf3ce46685f30fd28662501bf387e9d16e1 (patch) | |
| tree | 84cd5649ed2252f2d3722a955100a46f92629777 /kombu/transport/redis.py | |
| parent | 8a542d71c8a973f9b3a41b02ffec48a0f79a6de5 (diff) | |
| download | kombu-8786acf3ce46685f30fd28662501bf387e9d16e1.tar.gz | |
Return on connection error
Diffstat (limited to 'kombu/transport/redis.py')
| -rw-r--r-- | kombu/transport/redis.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/kombu/transport/redis.py b/kombu/transport/redis.py index 82ff3c4e..5488a6a9 100644 --- a/kombu/transport/redis.py +++ b/kombu/transport/redis.py @@ -481,6 +481,7 @@ class Channel(virtual.Channel): response = c.parse_response() except self.connection_errors: self._in_listen = False + return if response is not None: payload = self._handle_message(c, response) if bytes_to_str(payload['type']) == 'message': |