kutt/server/queues/queues.js

const Queue = require("bull");
const path = require("path");

const env = require("../env");

const redis = {
  port: env.REDIS_PORT,
  host: env.REDIS_HOST,
  db: env.REDIS_DB,
  ...(env.REDIS_PASSWORD && { password: env.REDIS_PASSWORD })
};

const visit = new Queue("visit", { redis });
visit.clean(5000, "completed");
visit.process(6, path.resolve(__dirname, "visit.js"));
visit.on("completed", job => job.remove());

// TODO: handler error
// visit.on('error', function (error) {
//   console.log('error');
// })

module.exports = { 
  visit,
}