bull-priority-queue-bug.js

var PQ = require("bull/lib/priority-queue");

var testQ = PQ("test:seek", 7777, '127.0.0.1');

var priorities = [
  "low",
  "normal",
  "medium",
  "high",
  "critical"
];

var delay = 1000;
var activeJob = 0;

testQ.process(function(job, jobDone) {
  activeJob++;
  // console.log("job", job.jobId, "started");
  // console.log("job priority", job.data.rand);
  console.log("active jobs in progress", activeJob);
  setTimeout(function(){
    activeJob--;
    // console.log("job", job.jobId, "done");
    jobDone();
  },delay * 3);
});

testQ.resume();
testQ.resume();
testQ.resume();
testQ.resume();
testQ.resume();

// generator
setInterval(function() {
  var rand = priorities[Math.floor(Math.random() * priorities.length)];
  testQ.add({rand: rand}, {
    priority: rand
  });
}, delay);