diff --git a/src/database/mongo/pubsub.js b/src/database/mongo/pubsub.js
index 8244c884d8..d29065a68d 100644
--- a/src/database/mongo/pubsub.js
+++ b/src/database/mongo/pubsub.js
@@ -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;