bullmqWorker.js

Go to the documentation of this file.

// BullMQ Worker for scheduled/delayed jobs
const { Worker, Queue } = require('bullmq');
const Redis = require('ioredis');
 
const redisConfig = require('./config/redis');
const connection = new Redis({
  ...redisConfig,
  maxRetriesPerRequest: null // Fix BullMQ error
});
const queue = new Queue('jobs', { connection });
 
const worker = new Worker('jobs', async job => {
  // Example job types: billing, review, backup, report
  switch(job.name) {
    case 'billing':
      // Run billing automation
      console.log('Running billing job:', job.data);
      break;
    case 'review':
      // Send review email
      console.log('Sending review email:', job.data);
      break;
    case 'backup':
      // Run backup
      console.log('Running backup:', job.data);
      break;
    case 'report':
      // Generate report
      console.log('Generating report:', job.data);
      break;
    default:
      console.log('Unknown job:', job.name);
  }
}, { connection });
 
console.log('BullMQ Worker running for scheduled/delayed jobs.');