hot fix

Author: skadefro

OpenFlowNodeRED/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@openiap/nodered",
-  "version": "1.2.57",
+  "version": "1.2.58",
   "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

@@ -231,11 +231,10 @@ export class amqp_publisher_node {
     }
     async OnMessage(msg: any, ack: any) {
         try {
-            const result: any = {};
-            result.amqpacknowledgment = ack;
+            let result: any = {};
             let data = msg.data;
             if (!NoderedUtil.IsNullEmpty(data._msgid)) {
-                data = Object.assign(this.payloads[data._msgid], data);
+                result = Object.assign(this.payloads[data._msgid], data);
                 delete this.payloads[data._msgid];
             }
             result.payload = data.payload;

OpenFlowNodeRED/src/nodered/nodes/workflow_nodes.ts

@@ -176,6 +176,7 @@ export class workflow_in_node {
                     return;
                 }
                 const orgmsg = res[0];
+                delete orgmsg._msgid; // Keep each run seperate
                 if (orgmsg.payload === null || orgmsg.payload === undefined) {
                     orgmsg.payload = data;
                     data = orgmsg;

VERSION

@@ -1 +1 @@
-1.2.57
+1.2.58

package.json

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