Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion src/socketio/async_aiopika_manager.py
Original file line number Diff line number Diff line change
Expand Up @@ -43,12 +43,12 @@ def __init__(self, url='amqp://guest:guest@localhost:5672//',
raise RuntimeError('aio_pika package is not installed '
'(Run "pip install aio_pika" in your '
'virtualenv).')
super().__init__(channel=channel, write_only=write_only, logger=logger)
self.url = url
self._lock = asyncio.Lock()
self.publisher_connection = None
self.publisher_channel = None
self.publisher_exchange = None
super().__init__(channel=channel, write_only=write_only, logger=logger)

async def _connection(self):
return await aio_pika.connect_robust(self.url)
Expand Down
2 changes: 1 addition & 1 deletion src/socketio/async_redis_manager.py
Original file line number Diff line number Diff line change
Expand Up @@ -52,10 +52,10 @@ def __init__(self, url='redis://localhost:6379/0', channel='socketio',
'(Run "pip install redis" in your virtualenv).')
if not hasattr(aioredis.Redis, 'from_url'):
raise RuntimeError('Version 2 of aioredis package is required.')
super().__init__(channel=channel, write_only=write_only, logger=logger)
self.redis_url = url
self.redis_options = redis_options or {}
self._redis_connect()
super().__init__(channel=channel, write_only=write_only, logger=logger)

def _redis_connect(self):
if not self.redis_url.startswith('redis+sentinel://'):
Expand Down
2 changes: 1 addition & 1 deletion src/socketio/redis_manager.py
Original file line number Diff line number Diff line change
Expand Up @@ -75,10 +75,10 @@ def __init__(self, url='redis://localhost:6379/0', channel='socketio',
raise RuntimeError('Redis package is not installed '
'(Run "pip install redis" in your '
'virtualenv).')
super().__init__(channel=channel, write_only=write_only, logger=logger)
self.redis_url = url
self.redis_options = redis_options or {}
self._redis_connect()
super().__init__(channel=channel, write_only=write_only, logger=logger)

def initialize(self):
super().initialize()
Expand Down
2 changes: 1 addition & 1 deletion src/socketio/zmq_manager.py
Original file line number Diff line number Diff line change
Expand Up @@ -57,6 +57,7 @@ def __init__(self, url='zmq+tcp://localhost:5555+5556',
if not (url.startswith('zmq+tcp://') and r.search(url)):
raise RuntimeError('unexpected connection string: ' + url)

super().__init__(channel=channel, write_only=write_only, logger=logger)
url = url.replace('zmq+', '')
(sink_url, sub_port) = url.split('+')
sink_port = sink_url.split(':')[-1]
Expand All @@ -72,7 +73,6 @@ def __init__(self, url='zmq+tcp://localhost:5555+5556',
self.sink = sink
self.sub = sub
self.channel = channel
super().__init__(channel=channel, write_only=write_only, logger=logger)

def _publish(self, data):
pickled_data = pickle.dumps(
Expand Down
Loading