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

redis: _put must take kwargs

This commit is contained in:
Ask Solem 2010-10-20 15:32:39 +02:00
parent 93b16d9c5d
commit 1372e68d17
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
kombu/transport/pyredis.py
View File

@ -11,7 +11,6 @@ DEFAULT_DB = 0
class Channel(virtual.Channel): class Channel(virtual.Channel):
queues = {}
_client = None _client = None
def _new_queue(self, queue, **kwargs): def _new_queue(self, queue, **kwargs):
@ -33,7 +32,7 @@ class Channel(virtual.Channel):
return deserialize(item), dest return deserialize(item), dest
raise Empty() raise Empty()
def _put(self, queue, message): def _put(self, queue, message, **kwargs):
self.client.lpush(queue, serialize(message)) self.client.lpush(queue, serialize(message))
def _purge(self, queue): def _purge(self, queue):