From 96fd27005054e14f0717802120f96d5937b7924b Mon Sep 17 00:00:00 2001
From: JIN <o3ouuu@inu.ac.kr>
Date: Wed, 4 Dec 2024 12:17:27 +0900
Subject: [PATCH] =?UTF-8?q?=F0=9F=94=A7=20fix:=20=EB=8D=B0=EC=9D=B4?=
 =?UTF-8?q?=ED=84=B0=20=EB=8C=80=EC=8B=A0=20channel=EB=AA=85=EC=9D=84=20?=
 =?UTF-8?q?=EB=B3=B4=EB=82=B4=EB=8A=94=20=EC=98=A4=EB=A5=98=20=EC=88=98?=
 =?UTF-8?q?=EC=A0=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 BE/src/common/redis/redis.domain-service.ts           | 6 +++---
 BE/src/common/websocket/base-socket.domain-service.ts | 2 +-
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/BE/src/common/redis/redis.domain-service.ts b/BE/src/common/redis/redis.domain-service.ts
index 39fa2d5..118cb3a 100644
--- a/BE/src/common/redis/redis.domain-service.ts
+++ b/BE/src/common/redis/redis.domain-service.ts
@@ -72,9 +72,9 @@ export class RedisDomainService {
     await this.subscriber.subscribe(channel);
   }
 
-  on(callback: (message: string) => void) {
-    this.subscriber.on('message', (message) => {
-      callback(message);
+  on(callback: (channel: string, message: string) => void) {
+    this.subscriber.on('message', (channel, message) => {
+      callback(channel, message);
     });
   }
 
diff --git a/BE/src/common/websocket/base-socket.domain-service.ts b/BE/src/common/websocket/base-socket.domain-service.ts
index f215824..95ac62e 100644
--- a/BE/src/common/websocket/base-socket.domain-service.ts
+++ b/BE/src/common/websocket/base-socket.domain-service.ts
@@ -83,7 +83,7 @@ export class BaseSocketDomainService implements OnModuleInit {
       }, 60000);
     };
 
-    this.redisDomainService.on((message) => {
+    this.redisDomainService.on((channel, message) => {
       const dataList = message.split('^');
       this.socketDataHandlers.H0STCNT0(dataList);
     });