fix amqp reconnect for rpa

Author: skadefro

OpenFlowNodeRED/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@openiap/nodered",
-  "version": "1.2.103",
+  "version": "1.2.104",
   "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/rpa_nodes.ts

@@ -49,12 +49,15 @@ export class rpa_detector_node {
             this.localqueue = await NoderedUtil.RegisterQueue(WebSocketClient.instance, this.config.queue, (msg: QueueMessage, ack: any) => {
                 this.OnMessage(msg, ack);
             }, (msg) => {
+                this.localqueue = "";
                 if (this != null && this.node != null) this.node.status({ fill: "red", shape: "dot", text: "Disconnected" });
                 setTimeout(this.connect.bind(this), (Math.floor(Math.random() * 6) + 1) * 500);
             });
             this.node.status({ fill: "green", shape: "dot", text: "Connected" });
         } catch (error) {
+            this.localqueue = "";
             NoderedUtil.HandleError(this, error, null);
+            setTimeout(this.connect.bind(this), (Math.floor(Math.random() * 6) + 1) * 500);
         }
     }
     async OnMessage(msg: any, ack: any) {
@@ -154,13 +157,16 @@ export class rpa_workflow_node {
             this.localqueue = await NoderedUtil.RegisterQueue(WebSocketClient.instance, this.localqueue, (msg: QueueMessage, ack: any) => {
                 this.OnMessage(msg, ack);
             }, (msg) => {
+                this.localqueue = "";
                 if (this != null && this.node != null) this.node.status({ fill: "red", shape: "dot", text: "Disconnected" });
                 setTimeout(this.connect.bind(this), (Math.floor(Math.random() * 6) + 1) * 500);
             });
             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) * 500);
         }
     }
     async OnMessage(msg: any, ack: any) {
@@ -365,13 +371,16 @@ export class rpa_killworkflows_node {
             this.localqueue = await NoderedUtil.RegisterQueue(WebSocketClient.instance, this.localqueue, (msg: QueueMessage, ack: any) => {
                 this.OnMessage(msg, ack);
             }, (msg) => {
+                this.localqueue = "";
                 if (this != null && this.node != null) this.node.status({ fill: "red", shape: "dot", text: "Disconnected" });
                 setTimeout(this.connect.bind(this), (Math.floor(Math.random() * 6) + 1) * 500);
             });
             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) * 500);
         }
     }
     async OnMessage(msg: any, ack: any) {

VERSION

@@ -1 +1 @@
-1.2.103
+1.2.104

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@openiap/openflow",
-  "version": "1.2.103",
+  "version": "1.2.104",
   "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": {