fix reconnect for workflow, add longer retry timer

Author: skadefro

OpenFlowNodeRED/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@openiap/nodered",
-  "version": "1.2.104",
+  "version": "1.2.105",
   "description": "Simple wrapper around NodeRed, RabbitMQ and MongoDB to support a more scaleable NodeRed implementation.\r Also the \"backend\" for [OpenRPA](https://github.com/skadefro/OpenRPA)",
   "main": "index.js",
   "scripts": {

OpenFlowNodeRED/src/nodered/nodes/amqp_nodes.ts

@@ -132,7 +132,7 @@ export class amqp_consumer_node {
             this.node.status({ fill: "green", shape: "dot", text: "Connected " + this.localqueue });
         } catch (error) {
             NoderedUtil.HandleError(this, error, null);
-            setTimeout(this.connect.bind(this), (Math.floor(Math.random() * 6) + 1) * 500);
+            setTimeout(this.connect.bind(this), (Math.floor(Math.random() * 6) + 1) * 2000);
         }
     }
     async OnMessage(msg: any, ack: any) {
@@ -242,7 +242,7 @@ export class amqp_publisher_node {
         } catch (error) {
             this.localqueue = "";
             NoderedUtil.HandleError(this, error, null);
-            setTimeout(this.connect.bind(this), (Math.floor(Math.random() * 6) + 1) * 500);
+            setTimeout(this.connect.bind(this), (Math.floor(Math.random() * 6) + 1) * 2000);
         }
     }
     async OnMessage(msg: any, ack: any) {
@@ -421,7 +421,7 @@ export class amqp_exchange_node {
             this.node.status({ fill: "green", shape: "dot", text: "Connected " + result.exchangename });
         } catch (error) {
             NoderedUtil.HandleError(this, error, null);
-            setTimeout(this.connect.bind(this), (Math.floor(Math.random() * 6) + 1) * 500);
+            setTimeout(this.connect.bind(this), (Math.floor(Math.random() * 6) + 1) * 2000);
         }
     }
     async OnMessage(msg: any, ack: any) {

OpenFlowNodeRED/src/nodered/nodes/rpa_nodes.ts

@@ -57,7 +57,7 @@ export class rpa_detector_node {
         } catch (error) {
             this.localqueue = "";
             NoderedUtil.HandleError(this, error, null);
-            setTimeout(this.connect.bind(this), (Math.floor(Math.random() * 6) + 1) * 500);
+            setTimeout(this.connect.bind(this), (Math.floor(Math.random() * 6) + 1) * 2000);
         }
     }
     async OnMessage(msg: any, ack: any) {
@@ -166,7 +166,7 @@ export class rpa_workflow_node {
         } catch (error) {
             this.localqueue = "";
             NoderedUtil.HandleError(this, error, null);
-            setTimeout(this.connect.bind(this), (Math.floor(Math.random() * 6) + 1) * 500);
+            setTimeout(this.connect.bind(this), (Math.floor(Math.random() * 6) + 1) * 2000);
         }
     }
     async OnMessage(msg: any, ack: any) {
@@ -380,7 +380,7 @@ export class rpa_killworkflows_node {
         } catch (error) {
             this.localqueue = "";
             NoderedUtil.HandleError(this, error, null);
-            setTimeout(this.connect.bind(this), (Math.floor(Math.random() * 6) + 1) * 500);
+            setTimeout(this.connect.bind(this), (Math.floor(Math.random() * 6) + 1) * 2000);
         }
     }
     async OnMessage(msg: any, ack: any) {

OpenFlowNodeRED/src/nodered/nodes/workflow_nodes.ts

@@ -61,7 +61,9 @@ export class workflow_in_node {
             await this.init();
             this.node.status({ fill: "green", shape: "dot", text: "Connected " + this.localqueue });
         } catch (error) {
+            this.localqueue = "";
             NoderedUtil.HandleError(this, error, null);
+            setTimeout(this.connect.bind(this), (Math.floor(Math.random() * 6) + 1) * 2000);
         }
     }
     async init() {
@@ -519,7 +521,9 @@ export class assign_workflow_node {
                 }
             }
         } catch (error) {
+            this.localqueue = "";
             NoderedUtil.HandleError(this, error, null);
+            setTimeout(this.connect.bind(this), (Math.floor(Math.random() * 6) + 1) * 2000);
         }
     }
     async OnMessage(msg: any, ack: any) {

VERSION

@@ -1 +1 @@
-1.2.104
+1.2.105

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@openiap/openflow",
-  "version": "1.2.104",
+  "version": "1.2.105",
   "description": "Simple wrapper around NodeRed, RabbitMQ and MongoDB to support a more scaleable NodeRed implementation.\r Also the \"backend\" for [OpenRPA](https://github.com/skadefro/OpenRPA)",
   "main": "index.js",
   "scripts": {