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

  amqp.connect('amqp://localhost', function (error0, connection) {
    if (error0) {
      throw error0;
    }
    connection.createChannel(function (error1, ch) {
      if (error1) {
        throw error1;
      }

      var q = 'task_test';
      var msg = process.argv.slice(2).join(' ') || "Hello World!";

      ch.assertQueue(q, { durable: true });
      ch.sendToQueue(q, Buffer.from(msg), { persistent: true });
      console.log(" [x] Sent '%s'", msg);

    });
    setTimeout(function () {
      connection.close();
      process.exit(0);
    }, 500);
});

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

amqp.connect('amqp://localhost', function (error0, connection) {
  if (error0) {
    throw error0;
  }
  connection.createch(function (error1, ch) {
    if (error1) {
      throw error1;
    }

    var queue = 'task_test';

    ch.assertQueue(queue, {
      durable: true
    });
    ch.prefetch(1);  // 每次只接收一个，处理完了才再次接收
    console.log(" [*] Waiting for messages in %s. To exit press CTRL+C", queue);

    ch.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");
        ch.ack(msg); // 消息确认
      }, secs * 1000);

    }, {
        noAck: false  // 开启消息确认标识
    });
  });

});