From 07aa206f71995ffc92f744d40ae40973d1c54813 Mon Sep 17 00:00:00 2001
From: Timothy Pogue <me@pogue.dev>
Date: Tue, 13 Sep 2022 12:36:40 -0600
Subject: [PATCH] real fix for reconnecting

---
 freqtrade/rpc/external_message_consumer.py | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/freqtrade/rpc/external_message_consumer.py b/freqtrade/rpc/external_message_consumer.py
index ef2417225..f8e5315f9 100644
--- a/freqtrade/rpc/external_message_consumer.py
+++ b/freqtrade/rpc/external_message_consumer.py
@@ -205,14 +205,14 @@ class ExternalMessageConsumer:
                 continue
 
             except websockets.exceptions.ConnectionClosedOK:
-                # Successfully closed, just end
-                return
+                # Successfully closed, just keep trying to connect again indefinitely
+                continue
 
             except Exception as e:
                 # An unforseen error has occurred, log and stop
                 logger.error("Unexpected error has occurred:")
                 logger.exception(e)
-                break
+                continue
 
     async def _receive_messages(
         self,
@@ -256,7 +256,7 @@ class ExternalMessageConsumer:
                         f"Ping error {channel} - retrying in {self.sleep_time}s")
                     await asyncio.sleep(self.sleep_time)
 
-                    continue
+                    break
 
     def handle_producer_message(self, producer: Dict[str, Any], message: Dict[str, Any]):
         """