v6.7.1 - Don't always reboot worker if broker crashes

Author: jondubois

index.js

@@ -108,6 +108,7 @@ SocketCluster.prototype._init = function (options) {
     tcpSynBacklog: null,
     workerController: null,
     brokerController: null,
+    brokerConnectRetryErrorThreshold: null,
     initController: null,
     rebootOnSignal: true,
     downgradeToUser: false,

kubernetes/socketcluster-deployment.yaml

@@ -11,7 +11,7 @@ spec:
     spec:
       containers:
       - name: socketcluster
-        image: socketcluster/socketcluster:v6.7.0
+        image: socketcluster/socketcluster:v6.7.1
         ports:
         - containerPort: 8000
         env:

lib/scworker.js

@@ -95,7 +95,8 @@ SCWorker.prototype._init = function (options) {
   this.brokerEngineClient = new this.brokerEngine.Client({
     brokers: this.options.brokers,
     secretKey: this.options.secretKey,
-    pubSubBatchDuration: this.options.pubSubBatchDuration
+    pubSubBatchDuration: this.options.pubSubBatchDuration,
+    connectRetryErrorThreshold: this.options.brokerConnectRetryErrorThreshold
   });
 
   this.brokerEngineClient.on('error', function (err) {
@@ -107,8 +108,8 @@ SCWorker.prototype._init = function (options) {
     }
     self._errorDomain.emit('error', error);
   });
-  this.brokerEngineClient.on('warning', function () {
-    self.warningHandler.apply(self, arguments);
+  this.brokerEngineClient.on('warning', function (warning) {
+    self.warningHandler(warning);
   });
   this.exchange = this.global = this.brokerEngineClient.exchange();
 

package.json

@@ -1,7 +1,7 @@
 {
   "name": "socketcluster",
   "description": "SocketCluster - A Highly parallelized WebSocket server cluster to make the most of multi-core machines/instances.",
-  "version": "6.7.0",
+  "version": "6.7.1",
   "homepage": "http://socketcluster.io",
   "contributors": [
     {
@@ -20,7 +20,7 @@
     "inquirer": "1.1.3",
     "minimist": "1.1.0",
     "sc-auth": "~4.1.1",
-    "sc-broker-cluster": "~4.2.0",
+    "sc-broker-cluster": "~4.2.2",
     "sc-domain": "~1.0.1",
     "sc-emitter": "~1.1.0",
     "sc-errors": "~1.3.3",

sample/package.json

@@ -18,7 +18,7 @@
     "sc-hot-reboot": "~1.0.0",
     "scc-broker-client": "~1.4.0",
     "serve-static": "1.11.2",
-    "socketcluster": "~6.7.0",
+    "socketcluster": "~6.7.1",
     "socketcluster-client": "~6.3.0"
   },
   "keywords": [