Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-10-26 16:46:12 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix: don't publish before pubClient is connected

Browse Source
This commit is contained in:
Barış Soner Uşaklı
2021-02-26 08:17:45 -05:00
parent 510eb1f981
commit cdf5d18f54
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -10,7 +10,7 @@ let channelName;
const PubSub = function () { const PubSub = function () {
const self = this; const self = this;
channelName = `db:${nconf.get('redis:database')}:pubsub_channel`; channelName = `db:${nconf.get('redis:database')}:pubsub_channel`;
self.queue = [];
connection.connect().then((client) => { connection.connect().then((client) => {
self.subClient = client; self.subClient = client;
self.subClient.subscribe(channelName); self.subClient.subscribe(channelName);
@@ -30,13 +30,20 @@ const PubSub = function () {
connection.connect().then((client) => { connection.connect().then((client) => {
self.pubClient = client; self.pubClient = client;
self.queue.forEach(payload => client.publish(channelName, payload));
self.queue.length = 0;
}); });
}; };
util.inherits(PubSub, EventEmitter); util.inherits(PubSub, EventEmitter);
PubSub.prototype.publish = function (event, data) { PubSub.prototype.publish = function (event, data) {
this.pubClient.publish(channelName, JSON.stringify({ event: event, data: data })); const payload = JSON.stringify({ event: event, data: data });
if (this.pubClient) {
this.pubClient.publish(channelName, payload);
} else {
this.queue.push(payload);
}
}; };
module.exports = new PubSub(); module.exports = new PubSub();