diff --git a/queue.js b/queue.js index 5eb0d1b4..71ed0879 100644 --- a/queue.js +++ b/queue.js @@ -2,14 +2,14 @@ const Queue = require('bull') , configs = require(__dirname+'/configs/main.json') - , generateQueue = new Queue('generate', { 'redis': configs.redis }); + , taskQueue = new Queue('task', { 'redis': configs.redis }); module.exports = { - queue: generateQueue, + queue: taskQueue, push: (data, options) => { - generateQueue.add(data, options); + taskQueue.add(data, options); } } diff --git a/worker.js b/worker.js index ec573f2d..a4a2bbb1 100644 --- a/worker.js +++ b/worker.js @@ -13,15 +13,15 @@ const Queue = require('bull') console.log('CONNECTING TO MONGODB'); await Mongo.connect(); - const buildTasks = require(__dirname+'/helpers/tasks.js') - , generateQueue = new Queue('generate', { 'redis': configs.redis }); + const tasks = require(__dirname+'/helpers/tasks.js') + , taskQueue = new Queue('task', { 'redis': configs.redis }); - generateQueue + taskQueue .on('error', console.error) .on('failed', console.warn); - generateQueue.process(async job => { - return buildTasks[job.data.task](job.data.options); + taskQueue.process(async job => { + return tasks[job.data.task](job.data.options); }); })();