node.jsとKueを使用すると、タイプに関係なく次のタスクを取得するためのコードがありますか？私はKUEがどのように機能するかを理解

Question

方法、私は私が取得するつもりだジョブの種類を指定する必要があります。

jobs.process('email', function(job, done){ 
    var pending = 5 
     , total = pending; 

    setInterval(function(){ 
     job.log('sending!'); 
     job.progress(total - pending, total); 
     --pending || done(); 
    }, 1000); 
    }); 

の電子メールは、「ジョブタイプです。私がしようとしているのは、タイプに関係なく待ち行列の次の仕事を得ることです。それは実践ですか？

参考までに、私のオブジェクトには、仕事と同じ名前のメソッドがありますので、どのような仕事を引き出しても問題はありません。

Answer 1

私が最終的に行ったことは、いくつかの幅広い種類の作業を行い、作業の一環として作業者の名前をすべて挿入することでした。

jobs.process('social_post', function(job, done){ 
    var this_worker = factory(job.data.worker); 
    this_worker(job,done); 
    }); 

工場は非常に単純です：私はKUEさんすでにフル機能のタスク管理のためのやり過ぎのように応答キューを使用してい

var worker_factory = function(worker_name) { 
    switch(worker_name){ 
     case 'facebook': 
      return FacebookWorker; 
     case 'social_response': 
      return SocialResponder; 

    }; 
}; 

コードは次のように見てしまいました。

これが役に立ちます。