mirror of https://github.com/celery/kombu.git
Since virtual broker state is now global, so must the Redis server mock be
This commit is contained in:
parent
5494317a04
commit
b5f92c4929
|
@ -18,13 +18,13 @@ class ResponseError(Exception):
|
||||||
|
|
||||||
|
|
||||||
class Client(object):
|
class Client(object):
|
||||||
|
queues = {}
|
||||||
|
sets = {}
|
||||||
|
|
||||||
def __init__(self, db=None, port=None, **kwargs):
|
def __init__(self, db=None, port=None, **kwargs):
|
||||||
self.port = port
|
self.port = port
|
||||||
self.db = db
|
self.db = db
|
||||||
self._called = []
|
self._called = []
|
||||||
self.queues = {}
|
|
||||||
self.sets = {}
|
|
||||||
self._connection = None
|
self._connection = None
|
||||||
self.bgsave_raises_ResponseError = False
|
self.bgsave_raises_ResponseError = False
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue