feat(connector.py): call on_message() on receive

2025-09-22 21:18:28 +02:00
parent b7562703dd
commit 5261ad8e9f
1 changed files with 1 additions and 0 deletions
--- a/src/judas_client/connector.py
+++ b/src/judas_client/connector.py
@@ -180,6 +180,7 @@ class Connector:
                    self.logger.error(f"[!] Failed to parse message: {e}")
                    continue
                self.logger.info(f"[*] Message received: {message}")
+                self.on_message(message)

            # if self._check_ack():
            #     self.logger.debug("[.] ACK verified")