#!/usr/bin/env node

var amqp = require('amqplib/callback_api');

amqp.connect('amqp://localhost', function(error, connection) {

connection.createChannel(function(error, channel) {

var queue = 'task_queue';

channel.assertQueue(queue, {

durable: true,

arguments: { 'x-queue-type': 'quorum' }

});

channel.prefetch(1);

console.log(" [*] Waiting for messages in %s. To exit press CTRL+C", queue);

channel.consume(queue, function(msg) {

var secs = msg.content.toString().split('.').length - 1;

console.log(" [x] Received %s", msg.content.toString());

setTimeout(function() {

console.log(" [x] Done");

channel.ack(msg);

}, secs * 1000);

}, {

noAck: false

});

});

});