Handle redis publish/subscribe connection error (#72)
diff --git a/provider/app.js b/provider/app.js
index ecfe146..1d9ea20 100755
--- 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 dcbdad5..5008c70 100644
--- a/provider/lib/utils.js
+++ b/provider/lib/utils.js
@@ -360,6 +360,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)