在Kue作业完成后执行回调

Question

我见过像this这样的问题，但他们没有回答我的问题。

我有个功能

var kue = require('kue');
var jobs = kue.createQueue();

var create_job = function(data, callback){
    jobs.create('job', {
        stuff: data   
    }).save();
}

如何才能使callback在jobs.process('job', function(job, done){ ...完成时被调用？

Answer 1

我以前没有使用过kue，所以这与它们的文档无关：

var kue = require('kue');
var jobs = kue.createQueue();

var create_job = function(data, callback){
    var job = jobs.create('job', {
        stuff: data   
    }).save();
    job.on('complete', function(){
        callback();
    }).on('failed', function(){
      callback({error: true});
    });    
};

我已经创建/使用了一个JavaScript闭包来捕获callback参数的值(通过附加create_job函数范围内的事件，然后在函数完成(或失败)时调用它)。