return error callback

interviewstreet · Jun 30, 2018 · f1c0234 · f1c0234
1 parent cb20e46
commit f1c0234
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 3 deletions.
diff --git a/client/index.js b/client/index.js
@@ -20,11 +20,17 @@ function Client(url, retryAttempts) {
   /** @type {Number} */
   this._reopenTimeout = null;
   /** @type {Number} */
-  this._retryAttempts = retryAttempts || 3;;
+  this._retryAttempts = retryAttempts || 3;
   /** @type {Number} */
   this._counter = 0;
+  /** @type {Function} */
+  this._errorCallback = null;
 }
 
+Client.prototype.onCaptureError = function(callback) {
+  this._errorCallback = callback;
+};
+
 Client.prototype.open = function() {
   clearTimeout(this._reopenTimeout);
   this._reopenTimeout = null;
@@ -47,7 +53,9 @@ Client.prototype._reopen = function() {
       this._counter++;
       this.open();
     } else {
-      throw new Error('Reached max retryAttempts');
+      if (typeof this._errorCallback === 'function') {
+        this._errorCallback(new Error('Reached max retryAttempts'));
+      }
     }
   }.bind(this), 1000 * this._counter);
 };

diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "socket-redis",
-  "version": "3.3.1",
+  "version": "3.3.2",
   "description": "Redis to SockJS relay",
   "main": "socket-redis.js",
   "bin": {