feat: log errors from mubsub

v1.18.x
Barış Soner Uşaklı 5 years ago
parent 57dce269c3
commit b01a47cbc1

@ -2,6 +2,9 @@
const mubsub = require('mubsub-nbb');
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;

Loading…
Cancel
Save