3 \]^ @shddlZddlZddlZy ddlZWnek r<dZYnXddlmZejdZGdddeZ dS)N) PubSubManagersocketiocsReZdZdZdZdfdd Zfd d Zd d Zd dZddZ ddZ Z S) RedisManageraCRedis based client manager. This class implements a Redis backend for event sharing across multiple processes. Only kept here as one more example of how to build a custom backend, since the kombu backend is perfectly adequate to support a Redis message queue. To use a Redis backend, initialize the :class:`Server` instance as follows:: url = 'redis://hostname:port/0' server = socketio.Server(client_manager=socketio.RedisManager(url)) :param url: The connection URL for the Redis server. For a default Redis store running on the same host, use ``redis://``. :param channel: The channel name on which the server sends and receives notifications. Must be the same in all the servers. :param write_only: If set ot ``True``, only initialize to emit events. The default of ``False`` initializes the class for emitting and receiving. :param redis_options: additional keyword arguments to be passed to ``Redis.from_url()``. redisredis://localhost:6379/0rFNcsBtdkrtd||_|pi|_|jtt|j|||ddS)NzLRedis package is not installed (Run "pip install redis" in your virtualenv).)channel write_onlylogger)r RuntimeError redis_url redis_options_redis_connectsuperr__init__)selfurlrr r r ) __class__A/tmp/pip-build-mqc4i71p/python-socketio/socketio/redis_manager.pyr)s  zRedisManager.__init__csltt|jd}|jjdkr4ddlm}|d}n d|jjkrTddlm}|d}|sht d|jjdS) NTZeventletr)is_monkey_patchedsocketZgevent)is_module_patchedzs