Кью io.redis кластер не может создавать и обрабатывать задания

Я пишу простой код для проверки выполнения задания после добавления нескольких портов в kue,ioredis, но кажется, что очередь не печатает какой-либо процесс задания

var ioRedis = require('ioredis');
var kue = require('kue');

var queue = kue.createQueue({
redis: {
    createClientFactory: function () {
        return new ioRedis.Cluster([
            {port: 7000},
            {port: 7001}])
            .on('connect', function () {
                console.log('Redis connection has been established!');

            }).on('end', function () {
                console.log('Redis connection has been closed');
            }).on('reconnecting', function () {
                console.log('Redis is trying to re-connect');
            }).on('error', function (error) {
                console.log('Error while connecting to Redis!!!');
            }).on('+node', function (data) {
                console.log('node is connected');
            }).on('-node', function (data) {
                console.log('node is disconnected');
            });   
         }
        }
     });

      function newJob() {
        var job = queue.create('new_job');
         job.save();
      }
     queue.process('new_job', function (job, done) {
          console.log('Job', job.id, 'is done');
          done && done();
        });
      setInterval(newJob, 1000);

Любая помощь!

0 ответов

Другие вопросы по тегам