amqp.html

<script type="text/x-red" data-template-name="amqp-connection">
    <div class="form-row">
        <label><i class="icon-host"></i> Host</label>
        <input type="text" id="node-config-input-host">
    </div>
    <div class="form-row">
        <label><i class="icon-bookmark"></i> Username</label>
        <input type="text" id="node-config-input-username">
    </div>
    <div class="form-row">
        <label><i class="icon-bookmark"></i> Password</label>
        <input type="text" id="node-config-input-password" style="-webkit-text-security: disc;">
    </div>
    <div class="form-row">
        <label ><i class="fa fa-tag"></i> Name</label>
        <input type="text" id="node-config-input-name" placeholder="Node name">
    </div>
</script>
<script type="text/javascript">
    RED.nodes.registerType('amqp-connection', {
        category: 'config',
        defaults: {
            host: { value: "", required: true },
            name: { value: "" },
        },
        credentials: {
            username: { type: "text" },
            password: { type: "password" }
        },
        label: function () {
            return (this.name || this.host) || "amqp credentials";
        }
    });
</script>


<script type="text/x-red" data-template-name="amqp consumer">
<div class="form-row">
    <label for="node-input-config"><i class="fa fa-globe"></i> Config</label>
    <input type="text" id="node-input-config">
</div>
<div class="form-row">
    <label><i class="fa fa-tag"></i> Queue name</label>
    <input type="text" id="node-input-queue" placeholder="Queue name">
</div>
<div class="form-row">
    <label><i class="fa fa-tag"></i> Name</label>
    <input type="text" id="node-input-name" placeholder="Node name">
</div>
</script>
<script type="text/x-red" data-help-name="amqp consumer">
AMQP consumer, listening for messages.<br>
if no connection is added, it will connect to your current openflow, but you
can add a connection to another openflow and send/receive message queue message using that.<br>
Remember that your queue maybe get prefixed with your usename, if amqp_force_queue_prefix is enabled in the openflow api<br>
</script>
<script type="text/javascript">
    RED.nodes.registerType('amqp consumer', {
        category: 'amqp',
        color: "#a6bbcf",
        defaults: {
            queue: { value: "", required: true },
            name: { value: "" },
            config: { value: "", type: "amqp-connection", required: false }
        },
        inputs: 0,
        outputs: 1,
        outputLabels: ["completed", "error"],
        icon: "bridge.png",
        label: function () {
            return this.name || "amqp consumer";
        },
        labelStyle: function () {
            return this.name ? "node_label_italic" : "";
        },

    });
</script>




<script type="text/x-red" data-template-name="amqp publisher">
<div class="form-row">
    <label for="node-input-config"><i class="fa fa-globe"></i> Config</label>
    <input type="text" id="node-input-config">
</div>
<div class="form-row">
    <label><i class="fa fa-tag"></i> Queue name</label>
    <input type="hidden" id="node-input-queuetype">
    <input style="width:70%" type="text" id="node-input-queue" placeholder="Queue name">
</div>
<div class="form-row">
    <label><i class="fa fa-tag"></i> Exchange name</label>
    <input type="hidden" id="node-input-exchangetype">
    <input style="width:70%" type="text" id="node-input-exchange" placeholder="Queue name">
</div>
<div class="form-row">
    <label><i class="fa fa-tag"></i> Routing key</label>
    <input type="hidden" id="node-input-routingkeytype">
    <input style="width:70%" type="text" id="node-input-routingkey" placeholder="Routing key">
</div>
<div class="form-row">
    <label><i class="fa fa-tag"></i> Local queue name</label>
    <input type="text" id="node-input-localqueue" placeholder="Queue name">
</div>
<div class="form-row">
    <label><i class="fa fa-tag"></i> Striptoken</label>
    <input type="checkbox" id="node-input-striptoken" style="width: auto;">
</div>
<div class="form-row">
    <label><i class="fa fa-tag"></i> Name</label>
    <input type="text" id="node-input-name" placeholder="Node name">
</div>
</script>
<script type="text/x-red" data-help-name="amqp publisher">
AMQP publisher, sends messages to queue or exchange. queue is the exchange to send message too.<br>
localqueue is this nodes personal queue, leave blank for auto generated ( will change on every restart/Deploy )<br>
use msg.expiration to define how long a message will wait for a consumer to pick it up<br>
if no connection is added, it will connect to your current openflow, but you
can add a connection to another openflow and send/receive message queue message using that.<br>
Remember that your <b>consumer queue</b> maybe get prefixed with your usename, if amqp_force_queue_prefix is enabled in the openflow api<br>
</script>
<script type="text/javascript">
    function isValid() {
        const queue = this.queue == null || this.queue == "";
        const exchange = this.exchange == null || this.exchange == "";
        const routingkey = this.routingkey == null || this.routingkey == "";
        if (queue == false) return true;
        if (exchange == false) return true;
        // if (!exchange && !routingkey) return true;
        return false;
    }

    RED.nodes.registerType('amqp publisher', {
        category: 'amqp',
        color: "#a6bbcf",
        defaults: {
            queue: { value: "", validate: RED.validators.typedInput("queuetype"), validate: isValid },
            queuetype: { value: "" },
            exchange: { value: "", validate: RED.validators.typedInput("exchangetype"), validate: isValid },
            exchangetype: { value: "" },
            routingkey: { value: "", validate: RED.validators.typedInput("routingkeytype") },
            routingkeytype: { value: "" },
            localqueue: { value: "" },
            striptoken: { value: false },
            config: { value: "", type: "amqp-connection", required: false },
            name: { value: "" }
        },
        inputs: 1,
        outputs: 2,
        outputLabels: ["completed", "error"],
        icon: "bridge.png",
        label: function () {
            return this.name || "amqp publisher";
        },
        labelStyle: function () {
            return this.name ? "node_label_italic" : "";
        },
        oneditprepare: function () {
            if (this.queuetype === 'val') $("#node-input-queuetype").val('str');
            $("#node-input-queue").typedInput({
                default: 'str',
                typeField: $("#node-input-queuetype"),
                types: ['msg', 'str', 'flow', 'global', 'json']
            });
            if (this.exchangetype === 'val') $("#node-input-exchangetype").val('str');
            $("#node-input-exchange").typedInput({
                default: 'str',
                typeField: $("#node-input-exchangetype"),
                types: ['msg', 'str', 'flow', 'global', 'json']
            });
            if (this.routingkeytype === 'val') $("#node-input-routingkeytype").val('str');
            $("#node-input-routingkey").typedInput({
                default: 'str',
                typeField: $("#node-input-routingkeytype"),
                types: ['msg', 'str', 'flow', 'global', 'json']
            });
        },
    });
</script>



<script type="text/x-red" data-template-name="amqp acknowledgment">
    <div class="form-row">
        <label ><i class="fa fa-tag"></i> Name</label>
        <input type="text" id="node-input-name" placeholder="Node name">
    </div>
</script>
<script type="text/x-red" data-help-name="amqp acknowledgment">
Acknowledgment processing a AMQP message.
</script>
<script type="text/javascript">
    RED.nodes.registerType('amqp acknowledgment', {
        category: 'amqp',
        color: "#a6bbcf",
        defaults: {
            name: { value: "" }
        },
        inputs: 1,
        outputs: 1,
        icon: "bridge.png",
        align: "right",
        label: function () {
            return this.name || "amqp acknowledgment";
        },
        labelStyle: function () {
            return this.name ? "node_label_italic" : "";
        },

    });
</script>






<script type="text/x-red" data-template-name="amqp exchange">
    <!-- readonly onfocus="this.removeAttribute('readonly');" autocomplete="off" -->
<div class="form-row">
    <label for="node-input-config"><i class="fa fa-globe"></i> Config</label>
    <input type="text" id="node-input-config">
</div>
<div class="form-row">
    <label><i class="fa fa-tag"></i> Exchange name</label>
    <input type="text" id="node-input-exchange" placeholder="Exchange name">
</div>
<div class="form-row">
    <label><i class="fa fa-tag"></i> Algorithm</label>
    <select id="node-input-algorithm">
        <option value="direct">Direct</option>
        <option value="fanout">Fanout</option>
        <option value="topic">Topic</option>
        <option value="header">Header</option>
    </select>
</div>
<div class="form-row">
    <label><i class="fa fa-tag"></i> Routing Key</label>
    <input type="text" id="node-input-routingkey" placeholder="Routing Key">
</div>
<div class="form-row">
    <label><i class="fa fa-tag"></i> Name</label>
    <input type="text" id="node-input-name" placeholder="Node name">
</div>
</script>
<script type="text/x-red" data-help-name="amqp exchange">
registers an exchange, and create an comsumer listening for messages on the exchange.<br>
if no connection is added, it will connect to your current openflow, but you
can add a connection to another openflow and send/receive message queue message using that.<br>
Remember that your queue maybe get prefixed with your usename, if amqp_force_exchange_prefix is enabled in the openflow api<br>
</script>
<script type="text/javascript">
    RED.nodes.registerType('amqp exchange', {
        category: 'amqp',
        color: "#a6bbcf",
        defaults: {
            exchange: { value: "", required: true },
            name: { value: "" },
            routingkey: { value: "" },
            algorithm: { value: "fanout", required: true },
            config: { value: "", type: "amqp-connection", required: false }
        },
        inputs: 0,
        outputs: 1,
        outputLabels: ["completed", "error"],
        icon: "bridge.png",
        label: function () {
            return this.name || "amqp exchange";
        },
        labelStyle: function () {
            return this.name ? "node_label_italic" : "";
        },
    });
</script>