javascript - Kue作业完成后执行回调

Question

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

我有一个功能

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，然后在函数完成（或失败）时调用它。