2016-12-25 187 views
2

我试图用Kue的调度作业。检查是否存在队列

但我试图找到一种方法来检查,如果有一些名称的队列已经存在。

这是我的代码至今。 的问题是,它使创建队列每次我RAN节点。

我如何检查队列名称“电子邮件”已存在?

var queue = kue.createQueue(); 
      var job = queue.create('email', { 
       title: 'Welcome to the site', 
       to: '[email protected]', 
       template: 'welcome-email' 
      }).save(); 

      job.on('complete', function(result){ 
       console.log('Job completed with data ', result); 
      }); 

      kue.app.listen(3001); 

      queue.process('email', function(job, done){ 
       email('[email protected]', done); 
      }); 

      function email(address, done) { 
       console.log(address); 
       // email send stuff... 
       done(); 
      } 

回答

2

从我阅读文档,它指出,只有一个队列的实例是每个节点在此过程https://github.com/Automattic/kue#processing-jobs

我已经开始工作苦厄仅仅几天回创建和按我了解,只有一个您注册事件的实例。假设你有'email','sms'和'weeklynotifications'类型的工作。你会使用

queue.process('email', function(job, done){ 

    }); 

    queue.process('sms', function(job, done){ 

    }); 

    queue.process('weeklynotifications', function(job, done){ 

    }); 

因此,简而言之,如果你打算使用多个队列为每种任务与队列注册这样的事件,这是不可能的。所有类型的任务都有一个队列。