Rooba
/
kombu
mirror of https://github.com/celery/kombu.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Redis: Set channel.connection_errors in case channel is closed.

This commit is contained in:
Ask Solem 2012-01-31 14:22:31 +00:00
parent d5be3882c1
commit f79d43e98d
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
kombu/transport/redis.py
View File

@ -146,6 +146,7 @@ class Channel(virtual.Channel):
self.client.info()
self.connection.cycle.add(self) # add to channel poller.
self.connection_errors = self.connection.connection_errors
def basic_consume(self, queue, *args, **kwargs):
if queue in self._fanout_queues:
@ -192,7 +193,7 @@ class Channel(virtual.Channel):
response = None
try:
response = c.parse_response()
except self.connection.connection_errors:
except self.connection_errors:
self._in_listen = False
if response is not None:
payload = self._handle_message(c, response)
@ -215,7 +216,7 @@ class Channel(virtual.Channel):
dest__item = self.client.parse_response(self.client.connection,
"BRPOP",
**options)
except self.connection.connection_errors:
except self.connection_errors:
# if there's a ConnectionError, disconnect so the next
# iteration will reconnect automatically.
self.client.connection.disconnect()
@ -231,7 +232,7 @@ class Channel(virtual.Channel):
def _poll_error(self, type, **options):
try:
self.client.parse_response(type)
except self.connection.connection_errors:
except self.connection_errors:
pass
def _get(self, queue):