feat: log errors from mubsub

This commit is contained in:
Barış Soner Uşaklı
2019-10-21 16:12:52 -04:00
parent 57dce269c3
commit b01a47cbc1

View File

@@ -2,6 +2,9 @@
const mubsub = require('mubsub-nbb'); const mubsub = require('mubsub-nbb');
const connection = require('./connection'); const connection = require('./connection');
const client = mubsub(connection.getConnectionString(), connection.getConnectionOptions());
module.exports = client.channel('pubsub'); const client = mubsub(connection.getConnectionString(), connection.getConnectionOptions());
client.on('error', err => console.error(err));
const channel = client.channel('pubsub');
channel.on('error', err => console.error(err));
module.exports = channel;