The Complete Production SOP: How to Deploy and Run BullMQ Redis Job & Message Queue for TypeScript in Autonomous AI Agents

---
name: "bullmq-redis-typescript-job-queue"
description: "Orchestrate resilient, distributed task queues and repeatable jobs in Node.js and TypeScript."
metadata:
  author: "Taskforce"
  version: "1.0.0"
triggers:
  - "create bullmq worker"
  - "bullmq flowproducer parent child"
  - "schedule repeatable job bullmq"
permissions:
  fs_read: true
  fs_write: "workspace"
  shell_exec: false
  net_access: false
---

import { ConnectionOptions } from 'bullmq';

export const redisConnection: ConnectionOptions = {
  host: process.env.REDIS_HOST || '127.0.0.1',
  port: Number(process.env.REDIS_PORT) || 6379,
  password: process.env.REDIS_PASSWORD || undefined,
  maxRetriesPerRequest: null,
  enableReadyCheck: false,
};

import { Queue, Worker, Job } from 'bullmq';
import { redisConnection } from '../config/redis';

export interface EmailJobPayload {
  userId: string;
  email: string;
  template: string;
}

export const emailQueue = new Queue<EmailJobPayload>('email-delivery', {
  connection: redisConnection,
  defaultJobOptions: {
    attempts: 3,
    backoff: {
      type: 'exponential',
      delay: 1000,
    },
    removeOnComplete: {
      age: 3600,
      count: 1000,
    },
    removeOnFail: {
      age: 86400,
    },
  },
});

export const emailWorker = new Worker<EmailJobPayload>(
  'email-delivery',
  async (job: Job<EmailJobPayload>) => {
    // Procedural execution logic
    return { delivered: true, timestamp: Date.now() };
  },
  {
    connection: redisConnection,
    concurrency: 5,
  }
);

import { emailWorker } from './queues/emailQueue';

const shutdown = async (signal: string) => {
  console.log(`Received ${signal}. Shutting down BullMQ worker gracefully...`);
  await emailWorker.close();
  process.exit(0);
};

process.on('SIGTERM', () => shutdown('SIGTERM'));
process.on('SIGINT', () => shutdown('SIGINT'));