diff --git a/socketio/kombu_manager.py b/socketio/kombu_manager.py index 9906673..c699ca0 100644 --- a/socketio/kombu_manager.py +++ b/socketio/kombu_manager.py @@ -38,7 +38,7 @@ class KombuManager(PubSubManager): # pragma: no cover name = 'kombu' def __init__(self, url='amqp://guest:guest@localhost:5672//', - channel='socketio', write_only=False): + channel='socketio', write_only=False, **kwargs): if kombu is None: raise RuntimeError('Kombu package is not installed ' '(Run "pip install kombu" in your ' diff --git a/socketio/redis_manager.py b/socketio/redis_manager.py index 30f7978..34ce594 100644 --- a/socketio/redis_manager.py +++ b/socketio/redis_manager.py @@ -33,12 +33,14 @@ class RedisManager(PubSubManager): # pragma: no cover name = 'redis' def __init__(self, url='redis://localhost:6379/0', channel='socketio', - write_only=False): + write_only=False, **kwargs): if redis is None: raise RuntimeError('Redis package is not installed ' '(Run "pip install redis" in your ' 'virtualenv).') self.redis = redis.Redis.from_url(url) + if "client_name" in kwargs: + self.redis.client_setname(kwargs["client_name"]) self.pubsub = self.redis.pubsub() super(RedisManager, self).__init__(channel=channel, write_only=write_only) diff --git a/socketio/zmq_manager.py b/socketio/zmq_manager.py index d8995a0..3a63f07 100644 --- a/socketio/zmq_manager.py +++ b/socketio/zmq_manager.py @@ -50,7 +50,7 @@ class ZmqManager(PubSubManager): # pragma: no cover def __init__(self, url='zmq+tcp://localhost:5555+5556', channel='socketio', - write_only=False): + write_only=False, **kwargs): if zmq is None: raise RuntimeError('zmq package is not installed ' '(Run "pip install pyzmq" in your '