We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 8834115 commit d1be494Copy full SHA for d1be494
1 file changed
server/src/index.ts
@@ -12,6 +12,7 @@ import YAML from "yamljs";
12
import { setupRedisDataClient, closeRedisDataClient } from "./db/redis.js";
13
import { setupRedisAdapter, closeRedisAdapterClients } from "./sockets/redisAdapter.js";
14
import { CoordinationService } from "./services/coordination.service.js";
15
+import { NotificationService } from "./services/notification.service.js";
16
17
const PORT = CONFIG.PORT;
18
@@ -45,6 +46,9 @@ const startServer = async () => {
45
46
47
const redisAdapter = await setupRedisAdapter();
48
io.adapter(redisAdapter);
49
+
50
+ // Initialize Notification Service (SSE Redis Subscriber)
51
+ NotificationService.init();
52
53
// Initialize Socket Logic
54
setupSocket(io);
0 commit comments