include correlationId in reply

skadefro · skadefro · commit 163670e1b4c4 · 2020-03-20T20:47:25.000+01:00
diff --git a/OpenFlowNodeRED/src/nodered/nodes/workflow_nodes.ts b/OpenFlowNodeRED/src/nodered/nodes/workflow_nodes.ts
@@ -294,7 +294,7 @@ export class workflow_out_node {
                 data.values = msg.values;
                 data.jwt = msg.jwt;
 
-                this.con.SendMessage(JSON.stringify(data), msg.resultqueue, null, false);
+                this.con.SendMessage(JSON.stringify(data), msg.resultqueue, msg.correlationId, false);
             }
         } catch (error) {
             NoderedUtil.HandleError(this, error);
diff --git a/VERSION b/VERSION
@@ -1 +1 @@
-0.0.481
+0.0.482

Original file line number	Diff line number	Diff line change
`@@ -294,7 +294,7 @@ export class workflow_out_node {`
`294`	`294`	`data.values = msg.values;`
`295`	`295`	`data.jwt = msg.jwt;`
`296`	`296`
`297`		`- this.con.SendMessage(JSON.stringify(data), msg.resultqueue, null, false);`
	`297`	`+ this.con.SendMessage(JSON.stringify(data), msg.resultqueue, msg.correlationId, false);`
`298`	`298`	`}`
`299`	`299`	`} catch (error) {`
`300`	`300`	`NoderedUtil.HandleError(this, error);`