Fix Interactive Brokers client start (#1551)

nautechsystems · Mar 21, 2024 · 63dabdd · 63dabdd
1 parent 8642500
commit 63dabdd
Show file tree

Hide file tree

Showing 4 changed files with 106 additions and 95 deletions.
diff --git a/nautilus_trader/adapters/interactive_brokers/client/client.py b/nautilus_trader/adapters/interactive_brokers/client/client.py
@@ -526,7 +526,7 @@ async def _run_internal_msg_queue_processor(self) -> None:
         Continuously process messages from the internal incoming message queue.
         """
         self._log.debug(
-            "Client internal message queue started.",
+            "Client internal message queue processor started.",
         )
         try:
             while (
@@ -548,7 +548,7 @@ async def _run_internal_msg_queue_processor(self) -> None:
                 )
             )
         finally:
-            self._log.debug("Client TWS incoming message reader stopped.")
+            self._log.debug("Internal message queue processor stopped.")
 
     def _process_message(self, msg: str) -> bool:
         """

diff --git a/nautilus_trader/adapters/interactive_brokers/client/connection.py b/nautilus_trader/adapters/interactive_brokers/client/connection.py
@@ -106,10 +106,11 @@ async def _handle_reconnect(self) -> None:
             )
             await asyncio.sleep(self._reconnect_delay)
             await self._startup()
-            await self._resubscribe_all()  # should this not be done in _resume?
-            self._resume()
-        else:
-            self._reconnect_attempts = 0
+
+        self._log.info("Reconnection successful.")
+        self._reconnect_attempts = 0
+        await self._resubscribe_all()
+        self._resume()
 
     def _initialize_connection_params(self) -> None:
         """