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

ドキュメントでこれを見つけました: Processing Concurrency Processing Concurrency

デフォルトでは、 queue.process() への呼び出しは、処理のために一度に 1 つのジョブのみを受け入れます。メールの送信などの小さなタスクの場合、これは理想的ではないため、数値を渡すことで、このタイプのアクティブなジョブの最大数を指定できます。

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