remove re-registering queues

Author: skadefro

OpenFlow/src/amqpwrapper.ts

@@ -127,18 +127,18 @@ export class amqpwrapper {
                 }
             });
             // ROLLBACK
-            var keys = Object.keys(this.exchanges);
-            for (var i = 0; i < keys.length; i++) {
-                var q1: amqpexchange = this.exchanges[keys[i]];
-                this.AddExchangeConsumer(q1.exchange, q1.algorithm, q1.routingkey, q1.ExchangeOptions, null, q1.callback);
-            }
-            var keys = Object.keys(this.queues);
-            for (var i = 0; i < keys.length; i++) {
-                if (keys[i] != this.replyqueue.queue) {
-                    var q2: amqpqueue = this.queues[keys[i]];
-                    this.AddQueueConsumer(q2.queue, q2.QueueOptions, null, q2.callback);
-                }
-            }
+            // var keys = Object.keys(this.exchanges);
+            // for (var i = 0; i < keys.length; i++) {
+            //     var q1: amqpexchange = this.exchanges[keys[i]];
+            //     this.AddExchangeConsumer(q1.exchange, q1.algorithm, q1.routingkey, q1.ExchangeOptions, null, q1.callback);
+            // }
+            // var keys = Object.keys(this.queues);
+            // for (var i = 0; i < keys.length; i++) {
+            //     if (keys[i] != this.replyqueue.queue) {
+            //         var q2: amqpqueue = this.queues[keys[i]];
+            //         this.AddQueueConsumer(q2.queue, q2.QueueOptions, null, q2.callback);
+            //     }
+            // }
         } catch (error) {
             console.error(error);
             this.timeout = setTimeout(this.connect.bind(this), 1000);

OpenFlowNodeRED/package.json

@@ -1,6 +1,6 @@
 {
   "name": "openflow-nodered",
-  "version": "1.0.51",
+  "version": "1.0.52",
   "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": {
@@ -47,4 +47,4 @@
     "unhandled-rejection": "^1.0.0",
     "winston": "^3.3.3"
   }
-}
+}

VERSION

@@ -1 +1 @@
-1.0.51
+1.0.52

package.json

@@ -1,6 +1,6 @@
 {
   "name": "openiap",
-  "version": "1.0.51",
+  "version": "1.0.52",
   "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": {
@@ -87,4 +87,4 @@
     "webpack": "^4.43.0",
     "webpack-cli": "^3.3.12"
   }
-}
+}