Skip to content

Commit

Permalink
๐Ÿ”ง fix: ๋ฐ์ดํ„ฐ ๋Œ€์‹  channel๋ช…์„ ๋ณด๋‚ด๋Š” ์˜ค๋ฅ˜ ์ˆ˜์ •
Browse files Browse the repository at this point in the history
  • Loading branch information
uuuo3o committed Dec 4, 2024
1 parent c868640 commit 96fd270
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
6 changes: 3 additions & 3 deletions BE/src/common/redis/redis.domain-service.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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);
});
}

Expand Down
2 changes: 1 addition & 1 deletion BE/src/common/websocket/base-socket.domain-service.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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);
});
Expand Down

0 comments on commit 96fd270

Please sign in to comment.