rename those

merge-requests/208/head
fatchan 5 years ago
parent 64d61c1117
commit f5f981b525
  1. 6
      queue.js
  2. 10
      worker.js

@ -2,14 +2,14 @@
const Queue = require('bull') const Queue = require('bull')
, configs = require(__dirname+'/configs/main.json') , configs = require(__dirname+'/configs/main.json')
, generateQueue = new Queue('generate', { 'redis': configs.redis }); , taskQueue = new Queue('task', { 'redis': configs.redis });
module.exports = { module.exports = {
queue: generateQueue, queue: taskQueue,
push: (data, options) => { push: (data, options) => {
generateQueue.add(data, options); taskQueue.add(data, options);
} }
} }

@ -13,15 +13,15 @@ const Queue = require('bull')
console.log('CONNECTING TO MONGODB'); console.log('CONNECTING TO MONGODB');
await Mongo.connect(); await Mongo.connect();
const buildTasks = require(__dirname+'/helpers/tasks.js') const tasks = require(__dirname+'/helpers/tasks.js')
, generateQueue = new Queue('generate', { 'redis': configs.redis }); , taskQueue = new Queue('task', { 'redis': configs.redis });
generateQueue taskQueue
.on('error', console.error) .on('error', console.error)
.on('failed', console.warn); .on('failed', console.warn);
generateQueue.process(async job => { taskQueue.process(async job => {
return buildTasks[job.data.task](job.data.options); return tasks[job.data.task](job.data.options);
}); });
})(); })();

Loading…
Cancel
Save