amqp

new_task.js

#!/usr/bin/env node
// https://www.rabbitmq.com/tutorials/tutorial-two-javascript.html

var amqp = require('amqplib/callback_api')
const arr = ['1', '2', '3', '4', '5', '6', '7', '{a, "b"}'] // {a: 'b'}, ['a', 'b']
amqp.connect('amqp://localhost', function (err, conn) {
  if (err) console.warn(err)
  conn.createChannel(function (err, ch) {
    if (err) console.warn(err)

    var q = 'task_queue'

    for (let i = 0; i < arr.length; i++) {
      const msg = arr[i]

      ch.assertQueue(q, {durable: true}) // https://www.squaremobius.net/amqp.node/channel_api.html#channel_assertQueue
      ch.sendToQueue(q, Buffer.from(msg), {persistent: true}) // https://www.squaremobius.net/amqp.node/channel_api.html#channel_sendToQueue
      console.log(new Date(), ' [x] Sent "%s"', msg)
    }
  })
  setTimeout(function () { conn.close(); process.exit(0) }, 500)
})

worker.js

#!/usr/bin/env node

var amqp = require('amqplib/callback_api')

amqp.connect('amqp://localhost', function (err, conn) {
  if (err) console.warn(err)
  conn.createChannel(function (err, ch) {
    if (err) console.warn(err)
    var q = 'task_queue'

    ch.assertQueue(q, {durable: true}) // https://www.squaremobius.net/amqp.node/channel_api.html#channel_assertQueue
    ch.prefetch(1)
    console.log(' [*] Waiting for messages in %s. To exit press CTRL+C', q)
    ch.consume(q, function (msg) {
      var secs = msg.content.toString().split('.').length - 1

      console.log(new Date(), ' [x] Received %j', msg.content.toString())

      // if (JSON.parse(msg.content.toString()).a) {
      //   console.log('json gefunden', JSON.parse(msg.content.toString()).a)
      // }
      setTimeout(function () {
        console.log(new Date(), ' [x] Done')
        ch.ack(msg)
      }, secs * 1000)
    }, {noAck: false})
  })
})