12

Author: skadefro

OpenFlow/src/WebSocketClient.ts

@@ -128,7 +128,8 @@ export class WebSocketClient {
                 queuename = "unknown." + Math.random().toString(36).substr(2, 9); autoDelete = true;
             }
         }
-        var AssertQueueOptions: any = new Object(amqpwrapper.Instance().AssertQueueOptions);
+        // var AssertQueueOptions: any = new Object(amqpwrapper.Instance().AssertQueueOptions);
+        var AssertQueueOptions: any = Object.assign({}, (amqpwrapper.Instance().AssertQueueOptions));
         AssertQueueOptions.autoDelete = autoDelete;
         var queuename = await amqpwrapper.Instance().AddQueueConsumer(queuename, AssertQueueOptions, this.jwt, async (msg: any, options: QueueMessageOptions, ack: any, done: any) => {
             var _data = msg;

OpenFlowNodeRED/src/nodered/nodes/rpa_nodes.ts

@@ -146,8 +146,8 @@ export class rpa_workflow_node {
 
 
             if (correlationId != null && this.messages[correlationId] != null) {
-
-                result = new Object(this.messages[correlationId]);
+                // result = new Object(this.messages[correlationId]);
+                result = Object.assign({}, this.messages[correlationId]);
                 if (command == "invokecompleted" || command == "invokefailed" || command == "invokeaborted" || command == "error" || command == "timeout") {
                     delete this.messages[correlationId];
                 }

VERSION

@@ -1 +1 @@
-1.0.19
+1.0.20