0

我有以下代码用于发送邮件kue

require('dotenv').load();
const mailer = require('../helper/mailer');
const kue = require('kue'),
  queue   = kue.createQueue();

console.log("Starting server");
queue.process('email',function(job,done){
  console.log(job.data);
  mailer
    .prepareContext(job.data)
    .then(mailer.prepareBody)
    .then(mailer.prepareMail)
    .then(mailer.sendMail)
    .then((data)=>{
      console.log("Mail sent");
    })
    .catch((err)=>{
      console.log(err.message);
    });
});

queue.on('error',(err)=>{
  console.log(err);
});

问题是它只响应第一个事件。我必须重新启动脚本才能发送另一个。我在这里做错了吗？

我正在使用添加事件

helper.sendVerificationMail = function(data){
  return new Promise(function(fullfill,reject){
    try{
      var ctx = {};
      ctx.from = "account";
      ctx.to_email = data.email;
      ctx.subject = "Verifiy your email address";
      ctx.template = "signup";
      ctx.ctx = {};
      ctx.ctx.verification = data.verification;
      queue.create('email',ctx).save();
      fullfill(data);
    }catch(err){
      reject(err);
    }
  });
};
4

1 回答 1

0

我在文档中找到了这个： 处理并发 处理并发

默认情况下，对 queue.process() 的调用一次只接受一个作业进行处理。对于像发送电子邮件这样的小任务，这并不理想，所以我们可以通过传递一个数字来指定这种类型的最大活动作业：

queue.process('email', 20, function(job, done){
  // ...
});
于 2017-03-11T14:29:13.730 回答