使用node.js和Kue,有没有办法让我的代码抓住下一个任务,而不pipetypes?

我了解Kue的工作方式,我需要指定我将要获得的工作types:

jobs.process('email', function(job, done){ var pending = 5 , total = pending; setInterval(function(){ job.log('sending!'); job.progress(total - pending, total); --pending || done(); }, 1000); }); 

其中“电子邮件”是工作types。 我想要做的是无论types如何,都可以在队列中获得下一份工作。 那可行吗?

作为参考,我的对象的方法被命名为与作业相同的东西,所以不pipe我提出什么样的工作,我总是可以和我的工作人员一起处理。

我最终做的是做几个大类的任务,并把工作人员的姓名作为工作的一部分。 代码最终看起来像这样:

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

工厂很简单:

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

我正在使用响应者队列作为Kue已经全function的任务pipe理的矫枉过正。

希望这可以帮助。