Bullqueue blog - Add processor

processors.default.ts

import { Job } from 'bullmq';
import { JobType, Queues } from '../enum/queue.enum';
import QueueService from '../services/queue.service';

// these enums should be in a separate file and exported
enum Queues {
  DEFAULT = 'default',
}

enum JobType {
  PROCESS_PAYMENT = 'process-payment',
}

export default class DefaultProcessor {
  static async processPayment(job: Job) {
    const queue = new QueueService().getQueue(Queues.DEFAULT);
    if (!queue) return;

    console.log(`Process job with id ${job.id} from the ${Queues.DEFAULT} queue`);
  }
}