Queue Job Processor

This handles background job processing with BullMQ and Redis, giving you queues, workers, retry logic, and progress tracking. The implementation covers common patterns like email sending, image processing, webhook delivery, and report generation, with type-safe job definitions and exponential backoff for failures. It includes rate limiting, concurrency controls, and proper connection management for Redis. The worker examples show real integration points like S3 uploads and email rendering. If you need async tasks that survive server restarts or want to offload slow operations from your request cycle, this gives you the complete setup. The code is production-ready with monitoring hooks and configurable retention policies for completed jobs.

skills.sh installs: 295
GitHub stars: 63
last updated: Aug 21, 2026

View on GitHub

Install

$ npx -y skills add patricio0312rev/skills --skill queue-job-processor --agent claude-code

Installs into .claude/skills of the current project.

Files

Queue Job Processor

Build robust background job processing with BullMQ and Redis.

Core Workflow

Setup Redis: Configure connection
Create queues: Define job queues
Implement workers: Process jobs
Add job types: Type-safe job definitions
Configure retries: Handle failures
Add monitoring: Dashboard and alerts

Installation

npm install bullmq ioredis
npm install -D @types/ioredis

Redis Connection

// lib/redis.ts
import IORedis from 'ioredis';

export const redis = new IORedis(process.env.REDIS_URL!, {
  maxRetriesPerRequest: null, // Required for BullMQ
  enableReadyCheck: false,
});

export const redisSubscriber = new IORedis(process.env.REDIS_URL!, {
  maxRetriesPerRequest: null,
  enableReadyCheck: false,
});

Queue Setup

Define Job Types

// jobs/types.ts
export interface EmailJobData {
  to: string;
  subject: string;
  template: string;
  variables: Record<string, string>;
}

export interface ImageProcessingJobData {
  imageId: string;
  userId: string;
  operations: Array<{
    type: 'resize' | 'crop' | 'watermark';
    params: Record<string, any>;
  }>;
}

SKILL.md on GitHub