From 5261ad8e9fe6a07033395e6936713b48c29ae30c Mon Sep 17 00:00:00 2001
From: Artur Borecki <me@pufereq.pl>
Date: Mon, 22 Sep 2025 21:18:28 +0200
Subject: [PATCH] feat(connector.py): call `on_message()` on receive

---
 src/judas_client/connector.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/judas_client/connector.py b/src/judas_client/connector.py
index 67ae1bc..8fbc173 100644
--- 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")