nodejs Kue作业处理逻辑

Question

我有一个非常简单的逻辑问题.

我将在一个单独的应用服务器上运行作业处理逻辑.

我的工作处理应用程序将是一个独立的应用程序,无需处理任务.

在我的代码中,如何确保我的应用程序不断检查redis服务器的作业？ - 我需要在无限循环中运行代码吗？ - 或者我需要继续重新启动我的应用程序

或者在Kue有一些内置的机制,我在这里失踪了？

谢谢

Answer 1

请参阅文档 - https://github.com/Automattic/kue#processing-jobs

当有队列时，它会不断运行并挑选作业。

根据示例：

var kue = require('kue')
 , queue = kue.createQueue();

queue.process('email', function(job, done){
  email(job.data.to, done);
});

function email(address, done) {
  if(!isValidEmail(address)) {
    //done('invalid to address') is possible but discouraged
    return done(new Error('invalid to address'));
  }
  // email send stuff...
  done();
}