узел JS KUE для попытки и остановки процесса - PullRequest
Новая
       35

узел JS KUE для попытки и остановки процесса

0 голосов
/ 04 февраля 2019

Я пишу процесс nodeJS keu.Мое требование, если моя строка проверки очереди обновляется 5 раз через каждые 20 секунд.Если обновление 1-5, любое количество попыток, если условие выполнено успешно, останавливает полный процесс очереди, но повторяет попытку n, чтобы снова запустить.

это функция генерации очереди 

  var job = queue.create('email', {

    id: 1,

}).attempts(5).save( function(err){
  if( !err ) console.log( job.id );
});

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

}).on('failed attempt', function(errorMessage, doneAttempts){
  console.log('Job failed',doneAttempts);

}).on('failed', function(errorMessage){
  console.log('Job failed',errorMessage);

}).on('progress', function(progress, data){
  console.log('\r  job #' + job.id + ' ' + progress + '% complete with data ', data );

});

это функция процесса очереди 

    var email = async  (information, done)=> {
    var dummy = await DummyService.getRecord(information.id);

    if(dummy.receiver_id!=0){
      done(dummy);
    }
    return done(new Error('something wrong'));
});

    // others wise retry after 20 second
...