Bullmq queue

Skill DIYA73/nestjs-skills/bullmq-queue

8 Claude Code skills for NestJS backend development — module scaffolding, TypeORM, BullMQ queues, WebSocket gateways, JWT auth, Redis caching, Docker, and testing patterns.

Install

npx -y skills add DIYA73/nestjs-skills --skill bullmq-queue

Assembled from the repository path, not quoted from the project. Check it against their README if it does not work.

2 things to look at

no licenseNo license file was found in the repository. Code published without one is not open source by default, so using it at work is a question for whoever answers licensing questions where you are.
0 stars0 stars. Stars are a popularity signal and not a quality one, but at this level it is likely that nobody has read this closely except its author, and you would be relying on your own review.

What its author says it does

Copied from the file, not written here

BullMQ job queues, processors, retry logic, and scheduled jobs in NestJS.

SKILL.md

2.5 KB, 631 tokens by cl100k_base, as published. Nobody here has run it

bullmq-queue

BullMQ job queues, processors, retry logic, and scheduled jobs in NestJS.

Trigger

Use this skill when asked to:

Add a background job or queue
Process tasks asynchronously
Schedule recurring jobs (cron)
Handle retries and failed jobs

Constants

export const EMAIL_QUEUE = 'email';
export const EMAIL_JOBS = {
  SEND_WELCOME: 'send-welcome',
  SEND_RESET: 'send-reset',
} as const;

Producer Service

import { Injectable } from '@nestjs/common';
import { InjectQueue } from '@nestjs/bull';
import type { Queue } from 'bull';
import { EMAIL_QUEUE, EMAIL_JOBS } from './email.constants';

export interface SendWelcomeJobData {
  userId: string;
  email: string;
  name: string;
}

@Injectable()
export class EmailQueue {
  constructor(@InjectQueue(EMAIL_QUEUE) private readonly queue: Queue) {}

  async sendWelcome(data: SendWelcomeJobData): Promise<void> {
    await this.queue.add(EMAIL_JOBS.SEND_WELCOME, data, {
      attempts: 3,
      backoff: { type: 'exponential', delay: 2000 },
      removeOnComplete: 100,
      removeOnFail: 50,
    });
  }
}

Processor

import { Processor, Process, OnQueueFailed } from '@nestjs/bull';
import type { Job } from 'bull';
import { Logger } from '@nestjs/common';
import { EMAIL_QUEUE, EMAIL_JOBS } from './email.constants';
import type { SendWelcomeJobData } from './email.queue';

@Processor(EMAIL_QUEUE)
export class EmailProcessor {
  private readonly logger = new Logger(EmailProcessor.name);

  @Process(EMAIL_JOBS.SEND_WELCOME)
  async handleWelcome(job: Job<SendWelcomeJobData>): Promise<void> {
    this.logger.log(`Sending welcome email to ${job.data.email}`);
    // your logic here
  }

  @OnQueueFailed()
  onFailed(job: Job, error: Error): void {
    this.logger.error(`Job ${job.id} failed: ${error.message}`);
  }
}

Recurring Jobs

await this.queue.add('notify', {}, {
  repeat: { cron: '0 9 * * *' },
  jobId: 'daily-notification',
});

Module

@Module({
  imports: [BullModule.registerQueue({ name: EMAIL_QUEUE })],
  providers: [EmailQueue, EmailProcessor],
  exports: [EmailQueue],
})
export class EmailModule {}

Job Options Reference

{
  attempts: 3,
  backoff: { type: 'exponential', delay: 2000 },
  delay: 5000,
  priority: 1,
  timeout: 30000,
  removeOnComplete: 100,
  removeOnFail: 50,
  jobId: 'unique-id',
}

What ships with it

Read from the repository

Just SKILL.md. No reference files, no scripts.