diff --git a/socketio/redis_manager.py b/socketio/redis_manager.py
index cef7624..d3fe29d 100644
--- a/socketio/redis_manager.py
+++ b/socketio/redis_manager.py
@@ -92,6 +92,7 @@ class RedisManager(PubSubManager):  # pragma: no cover
         while True:
             try:
                 if connect:
+                    retry_sleep = 1
                     self._redis_connect()
                     self.pubsub.subscribe(self.channel)
                 for message in self.pubsub.listen():