Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2026-02-26 16:41:21 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix: pubsub on node-redis

Browse Source
This commit is contained in:
Barış Soner Uşaklı
2025-06-18 13:17:29 -04:00
parent 14043ab0fd
commit f7f70468fd
1 changed files with 1 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/database/redis/pubsub.js
View File

@@ -13,12 +13,7 @@ const PubSub = function () {
self.queue = []; self.queue = [];
connection.connect().then((client) => { connection.connect().then((client) => {
self.subClient = client; self.subClient = client;
self.subClient.subscribe(channelName); self.subClient.subscribe(channelName, (message) => {
self.subClient.on('message', (channel, message) => {
if (channel !== channelName) {
return;
}
try { try {
const msg = JSON.parse(message); const msg = JSON.parse(message);
self.emit(msg.event, msg.data); self.emit(msg.event, msg.data);