Add error output for timeouts and errors

Author: skadefro

OpenFlowNodeRED/src/nodered/nodes/amqp.html

@@ -61,6 +61,7 @@
         },
         inputs: 0,
         outputs: 1,
+        outputLabels: ["completed", "error"],
         icon: "bridge.png",
         label: function () {
             return this.name || "amqp consumer";
@@ -111,7 +112,8 @@
             config: { value: "", type: "amqp-connection", required: false }
         },
         inputs: 1,
-        outputs: 1,
+        outputs: 2,
+        outputLabels: ["completed", "error"],
         icon: "bridge.png",
         label: function () {
             return this.name || "amqp publisher";

OpenFlowNodeRED/src/nodered/nodes/amqp_nodes.ts

@@ -215,7 +215,12 @@ export class amqp_publisher_node {
             var data = msg.data;
             result.payload = data.payload;
             result.jwt = data.jwt;
-            this.node.send(result);
+            if (data.command == "timeout") {
+                result.error = "Message timed out, message was not picked up in a timely fashion";
+                this.node.send([null, result]);
+            } else {
+                this.node.send(result);
+            }
             ack();
         } catch (error) {
             NoderedUtil.HandleError(this, error);