Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-11-08 06:55:46 +01:00
Code Issues Packages Projects Releases Wiki Activity

closes #3014

Browse Source
This commit is contained in:
barisusakli
2015-04-14 11:01:11 -04:00
parent a055ff3547
commit 1cc80cbc84
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/pubsub.js
View File

@@ -6,6 +6,8 @@ var nconf = require('nconf'),
winston = require('winston'), winston = require('winston'),
EventEmitter = require('events').EventEmitter; EventEmitter = require('events').EventEmitter;
var channelName;
var PubSub = function() { var PubSub = function() {
var self = this; var self = this;
if (nconf.get('redis')) { if (nconf.get('redis')) {
@@ -13,10 +15,11 @@ var PubSub = function() {
var subClient = redis.connect(); var subClient = redis.connect();
this.pubClient = redis.connect(); this.pubClient = redis.connect();
subClient.subscribe('pubsub_channel'); channelName = 'db:' + nconf.get('redis:database') + 'pubsub_channel';
subClient.subscribe(channelName);
subClient.on('message', function(channel, message) { subClient.on('message', function(channel, message) {
if (channel !== 'pubsub_channel') { if (channel !== channelName) {
return; return;
} }
@@ -34,7 +37,7 @@ util.inherits(PubSub, EventEmitter);
PubSub.prototype.publish = function(event, data) { PubSub.prototype.publish = function(event, data) {
if (this.pubClient) { if (this.pubClient) {
this.pubClient.publish('pubsub_channel', JSON.stringify({event: event, data: data})); this.pubClient.publish(channelName, JSON.stringify({event: event, data: data}));
} else { } else {
this.emit(event, data); this.emit(event, data);
} }