Кью 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);
Любая помощь!