From 1372e68d174a0446e2353bf57730764376e72e40 Mon Sep 17 00:00:00 2001 From: Ask Solem Date: Wed, 20 Oct 2010 15:32:39 +0200 Subject: [PATCH] redis: _put must take kwargs --- kombu/transport/pyredis.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/kombu/transport/pyredis.py b/kombu/transport/pyredis.py index a5887883..f3de476d 100644 --- a/kombu/transport/pyredis.py +++ b/kombu/transport/pyredis.py @@ -11,7 +11,6 @@ DEFAULT_DB = 0 class Channel(virtual.Channel): - queues = {} _client = None def _new_queue(self, queue, **kwargs): @@ -33,7 +32,7 @@ class Channel(virtual.Channel): return deserialize(item), dest raise Empty() - def _put(self, queue, message): + def _put(self, queue, message, **kwargs): self.client.lpush(queue, serialize(message)) def _purge(self, queue):