diff --git a/cef_3M/util.py b/cef_3M/util.py
index f7d8122..1e5a874 100644
--- a/cef_3M/util.py
+++ b/cef_3M/util.py
@@ -76,7 +76,7 @@ class ErgoClient:
         async with redis.pubsub() as pubsub:
             await pubsub.psubscribe("user.*")
             while True:
-                message = await pubsub.get_message(ignore_subscribe_messages=True)
+                message = await pubsub.get_message(ignore_subscribe_messages=True, timeout=None)
                 try:
                     await self.handleUserMessage(message)
                 except Exception as e: