Bullqueue blog - Queue Service (add workers)

queue.service.ts

...
import DefaultProcessor from './processors.default';

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

export default class QueueService {
  ...

  constructor() {
    ...
    this.instantiateWorkers();
  }

  ...

  async instantiateWorkers() {
    this.defaultQueueWorker = new Worker(
      Queues.DEFAULT,
      async (job: Job) => {
        switch (job.name) {
          case JobType.PROCESS_PAYMENT:
            await DefaultProcessor.processPayment(job);
            break;
        }
        console.log('[DEFAULT QUEUE] Worker for default queue');
      },
      { connection: QueueService.QUEUE_OPTIONS.connection },
    );

    this.defaultQueueWorker.on('completed', (job: Job, value) => {
      console.log(
        `[DEFAULT QUEUE] Completed job with data\n
          Data: ${job.asJSON().data}\n
          ID: ${job.id}\n
          Value: ${value}
        `,
      );
    });

    this.defaultQueueWorker.on('failed', (job: Job, value) => {
      console.log(
        `[DEFAULT QUEUE] Failed job with data\n
          Data: ${job.asJSON().data}\n
          ID: ${job.id}\n
          Value: ${value}
        `,
      );
    });
  }
  
  ...
}