BullMQ Job Scheduler

BullMQ is used for asynchronous/background processing with Redis.

1. Registered Queues

Queue names are sourced from @nomor/jobs (QueueName enum). Current runtime registration is in:

apps/api/src/services/bullmq/bull.module.ts

Active queues include:

notifications
cart
orders
orders_maintenance
maintenance
orders_reservations
orders_stock_finalize
orders_stock_release
inventory

2. Service Usage

Use BullService with injected queue tokens.

import { InjectQueue } from "@nestjs/bullmq";
import { Injectable } from "@nestjs/common";
import { QueueName } from "@nomor/jobs";
import type { Queue } from "bullmq";
import { BullService } from "@/services/bullmq/bull.service";

@Injectable()
export class ExampleService {
  constructor(
    private readonly bullService: BullService,
    @InjectQueue(QueueName.ORDERS) private readonly ordersQueue: Queue,
  ) {}

  async enqueueOrderCancel(orderId: number, cancelledBy: string): Promise<void> {
    await this.bullService.addJob(
      this.ordersQueue,
      "order.cancel",
      { orderId, cancelledBy, cancelledByActorType: "customer" },
      { priority: 1 },
    );
  }
}

3. Best Practices

Keep payloads small and serializable
Use idempotent processors
Configure retries + exponential backoff
Set remove-on-complete/fail retention policies
Log start/success/failure with correlation IDs

BullMQ Job Scheduler

BullMQ Job Scheduler

1. Registered Queues

2. Service Usage

3. Best Practices

On this page