diff --git a/src/socketio/async_aiopika_manager.py b/src/socketio/async_aiopika_manager.py
index b6f09b8..003b67b 100644
--- a/src/socketio/async_aiopika_manager.py
+++ b/src/socketio/async_aiopika_manager.py
@@ -43,12 +43,12 @@ class AsyncAioPikaManager(AsyncPubSubManager):  # pragma: no cover
             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)
diff --git a/src/socketio/async_redis_manager.py b/src/socketio/async_redis_manager.py
index 6f248c2..92109a2 100644
--- a/src/socketio/async_redis_manager.py
+++ b/src/socketio/async_redis_manager.py
@@ -52,9 +52,9 @@ class AsyncRedisManager(AsyncPubSubManager):  # pragma: no cover
                                '(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 {}
-        super().__init__(channel=channel, write_only=write_only, logger=logger)
         self._redis_connect()
 
     def _redis_connect(self):
diff --git a/src/socketio/redis_manager.py b/src/socketio/redis_manager.py
index df98618..c4407df 100644
--- a/src/socketio/redis_manager.py
+++ b/src/socketio/redis_manager.py
@@ -75,10 +75,10 @@ class RedisManager(PubSubManager):  # pragma: no cover
             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()
diff --git a/src/socketio/zmq_manager.py b/src/socketio/zmq_manager.py
index 468dc26..aa5a49a 100644
--- a/src/socketio/zmq_manager.py
+++ b/src/socketio/zmq_manager.py
@@ -57,6 +57,7 @@ class ZmqManager(PubSubManager):  # pragma: no cover
         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]
@@ -72,7 +73,6 @@ class ZmqManager(PubSubManager):  # pragma: no cover
         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(