Kue

emptyKue.js

var kue = require('kue')
  , q = new kue;

// list all the active job ids
q.active(function(err, ids) {
  console.log(ids);
});

// remove all the active jobs
q.active(function(err, ids) {
  console.log(ids);
  for(i=0; i < ids.length; i ++) {

    kue.Job.get(ids[i], function(err, job) {
      job.remove();
    });

  };
});