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

Fixed typo client -> c

This commit is contained in:
Ask Solem 2011-01-28 20:31:12 +01:00
parent c39bf4606c
commit a9b53e89bc
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
kombu/transport/pyredis.py
View File

@ -178,7 +178,7 @@ class Channel(virtual.Channel):
except self.connection.connection_errors: except self.connection.connection_errors:
self._in_listen = False self._in_listen = False
if response is not None: if response is not None:
payload = self._handle_message(client, response) payload = self._handle_message(c, response)
if payload["type"] == "message": if payload["type"] == "message":
return (deserialize(payload["data"]), return (deserialize(payload["data"]),
self._fanout_to_queue[payload["channel"]]) self._fanout_to_queue[payload["channel"]])