diff options
| author | Ask Solem <ask@celeryproject.org> | 2014-03-05 12:52:55 +0000 |
|---|---|---|
| committer | Ask Solem <ask@celeryproject.org> | 2014-03-05 12:52:55 +0000 |
| commit | 4dc6eea13259e5ba4a9aae4e97a0ce1e97c03028 (patch) | |
| tree | 9c2e8392014baf3e61a48fa50742dd174724e97b | |
| parent | 0dd1ccdb17a9ece0c3fb2d0e633ed86c44fea08a (diff) | |
| download | kombu-4dc6eea13259e5ba4a9aae4e97a0ce1e97c03028.tar.gz | |
Do not close none connection. Closes #320
| -rw-r--r-- | kombu/transport/redis.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kombu/transport/redis.py b/kombu/transport/redis.py index 31eb6a8c..87288eda 100644 --- a/kombu/transport/redis.py +++ b/kombu/transport/redis.py @@ -551,7 +551,7 @@ class Channel(virtual.Channel): try: c.unsubscribe([topic]) finally: - if should_disconnect: + if should_disconnect and c.connection: c.connection.disconnect() def _handle_message(self, client, r): |