bull

consumer.js

var Bull = require('bull');
var queue = new Bull('contacts', 6383, 'localhost');

var concurrency = process.argv[2] ? parseInt(process.argv[2]) : 1;

function handler(job, done) {
  console.log('processing job', job.jobId);

  setTimeout(() => {
    done();
  }, 5 * 1000);
}

queue.on('stalled', job => console.log('stalled: ', job));

queue.process(handler, {
  concurrency: concurrency
});

producer.js

var Bull = require('bull');
var queue = new Bull('contacts', 6383, 'localhost');

var numEvents = process.argv[2] ? parseInt(process.argv[2]) : 1;

queue.on('ready', () => {
  for (var i = 0; i < numEvents; i++) {
    setTimeout(() => {
      queue.add({}, {
        removeOnComplete: true
      }).then(() => {
        console.log('published job');
      });
    }, i * 500);
  }
});