From 138852f87bcd168f901bac8ad2fdaef3e8f5d0b5 Mon Sep 17 00:00:00 2001
From: Wanjohi <71614375+wanjohiryan@users.noreply.github.com>
Date: Wed, 5 Nov 2025 19:02:36 +0300
Subject: [PATCH] fix: Remove unnecessary code in Event Bus

---
 packages/core/src/bus/index.ts | 21 ---------------------
 1 file changed, 21 deletions(-)

diff --git a/packages/core/src/bus/index.ts b/packages/core/src/bus/index.ts
index b40fb41d..9d336536 100644
--- a/packages/core/src/bus/index.ts
+++ b/packages/core/src/bus/index.ts
@@ -35,27 +35,6 @@ export namespace Bus {
         subClient.connect().catch(() => Promise.resolve()),
       ]);
 
-      // global dispatcher for incoming messages
-      subClient.subscribe("message", (channel: string, message: string) => {
-        const handlers = subscribers.get(channel);
-        if (!handlers?.length) return;
-        try {
-          const parsed = JSON.parse(message);
-          for (const h of handlers) {
-            // call handlers without awaiting so one slow handler doesn't block the dispatcher
-            try {
-              const r = h(parsed.detail, parsed) as any;
-              if (r instanceof Promise)
-                r.catch((e) => log.error("bus handler error", e));
-            } catch (e: any) {
-              log.error("bus handler error", e);
-            }
-          }
-        } catch (e: any) {
-          log.error("bus: failed to parse message", e);
-        }
-      });
-
       return { pubClient, subClient };
     } catch (err: any) {
       log.error("bus: failed to connect to redis", err);