|
|
|
@ -3,9 +3,9 @@
|
|
|
|
|
var mubsub = require('mubsub-nbb');
|
|
|
|
|
var db = require('../mongo');
|
|
|
|
|
const connString = db.getConnectionString();
|
|
|
|
|
const connOptions = db.getConnectionOptions();
|
|
|
|
|
var client = mubsub(connString, connOptions);
|
|
|
|
|
|
|
|
|
|
var client = mubsub(connString);
|
|
|
|
|
client.on('error', function (err) {
|
|
|
|
|
console.error('mongo pubsub error ' + connString, connOptions, err);
|
|
|
|
|
console.error('mongo pubsub error ' + connString, err);
|
|
|
|
|
});
|
|
|
|
|
module.exports = client.channel('pubsub');
|
|
|
|
|