Handle redis publish/subscribe connection error (#115)
diff --git a/provider/app.js b/provider/app.js
index 8195183..54b8934 100644
--- a/provider/app.js
+++ b/provider/app.js
@@ -106,7 +106,7 @@
});
client.on("error", function (err) {
- logger.error(method, 'Error creating redis', err);
+ logger.error(method, 'Error connecting to redis', err);
reject(err);
});
}
diff --git a/provider/lib/utils.js b/provider/lib/utils.js
index b31d84a..06d9d4d 100644
--- a/provider/lib/utils.js
+++ b/provider/lib/utils.js
@@ -413,6 +413,11 @@
}
});
+ subscriber.on("error", function (err) {
+ logger.error(method, 'Error connecting to redis', err);
+ reject(err);
+ });
+
subscriber.subscribe(utils.redisHash);
redisClient.hgetAsync(utils.redisHash, utils.redisKey)