#!/usr/bin/env node
"use strict";

let amqp = require('amqplib/callback_api');
// 'host' => '165.227.149.146',
//     'port' => '5672',
//     'user' => 'test',
//     'password' => 'test',

amqp.connect({
    hostname: '165.227.149.146',
    username: 'test',
    password: 'test'
}, function(err, conn) {
    conn.createChannel(function(err, channel) {

        let q = 'ParseImap';

        channel.assertExchange('delayer', 'x-delayed-message', {
            passive: false,
            durable: true,
            autoDelete: false,
            internal: false,
            nowait: true,
            arguments: {
                'x-delayed-type': 'direct'
            }
        });

        channel.assertQueue(q, {
            durable: true,
            passive: false,
            exclusive: false,
            autoDelete: false
        }, function(err, q1){
            channel.bindQueue(q, 'delayer', 'parse_imap');

            channel.consume(q, function(msg){
                console.log(msg.content.toString());
            }, {
                noAck: false
            });
        });
    });
});