var amqp = require('amqplib/callback_api');
var channel = null
var connection = null
var closeOnErr = function (err) {
    if (!err) return false;
    console.log("[AMQP] error", err);
    connection.close();
    return true;
}
var subscribe = function () {
    connection.createChannel(function (err, ch) {
        if (closeOnErr(err)) return;
        ch.on("error", function (err) {
            console.log("[AMQP] channel error", err.message);
        });
        ch.on("close", function () {
            console.log("[AMQP] channel closed");
        });
        channel = ch
        var ex = 'YOUR USERNAME'// YOUR USERNAME  emiza@emiza.com
        ch.assertExchange(ex, 'direct', {durable: false});
        ch.assertQueue('', {exclusive: true}, function (err, q) {
            console.log(" [*] Waiting for messages in %s. To exit press CTRL+C", q.queue);
            ch.bindQueue(q.queue, ex, '');
            ch.consume(q.queue, function (msg) {
                console.log(" [x] Received %s", msg.content.toString());
            }, {noAck: true});
        });
    });
};
function connectRabbitMq() {
    var username = "YOUR USERNAME"
    var password = "YOUR PASSWORD"
    var host = "fj7sfvkp934a.numadic.com"
    var url = "amqp://" + username + ":" + password + "@" + host;
    amqp.connect(url, function (err, conn) {
        if (err) {
            return setTimeout(connectRabbitMq, 2000);
        }
        conn.on('error', function (err) {
            console.log("[AMQP] conn error", err.message);
        });

        conn.on("close", function () {
            console.log("[AMQP] reconnecting");
            return setTimeout(connectRabbitMq, 1000);
        });
        connection = conn
        subscribe();
    });
}
connectRabbitMq()