src/judas_client/connector.py

@@ -167,8 +167,20 @@ class Connector:
             if not data:
                 self.reconnect()
                 continue
-            message = Message.from_bytes(data.strip())
+            for line in data.split(b"\n"):
-            self.logger.info(f"[<] Message received: {message}")
+                line: bytes = line.strip()
+
+                if not line:
+                    continue
+
+                self.logger.debug(f"[.] Raw message data: {line}")
+                try:
+                    message: Message = Message.from_bytes(line)
+                except ValueError as e:
+                    self.logger.error(f"[!] Failed to parse message: {e}")
+                    continue
+                self.logger.info(f"[*] Message received: {message}")
+
             # if self._check_ack():
             #     self.logger.debug("[.] ACK verified")
             # else: