@json-express/queue-bullmq

A distributed task queue adapter for JSONExpress powered by BullMQ.

Overview

Unlike queue-memory, the BullMQ queue adapter is designed for robust, scalable production environments. It guarantees reliable execution across multiple instances and seamlessly supports retries, delayed jobs, and distributed cron schedules.

Installation

npm install @json-express/queue-bullmq bullmq ioredis

Setup

Register the adapter during kernel boot:

// src/boot.ts
import { Kernel } from '@json-express/core';
import { QueueBullmq } from '@json-express/queue-bullmq';

export const kernel = new Kernel();

kernel.registerQueueAdapter(new QueueBullmq({
    connectionString: process.env.REDIS_URL || 'redis://localhost:6379',
    logger: kernel.logger
}));

Usage

This adapter implements the IQueueAdapter interface. This means you do not need to configure BullMQ directly. Simply enqueue jobs on the kernel, and queue-bullmq translates the generic constraints (delay, cron) into native BullMQ instructions.

// Fire and forget
await kernel.queue.enqueue('emails', 'sendWelcome', { to: 'user@example.com' });

// Run 10 seconds from now
await kernel.queue.enqueue('cleanup', 'deleteTemp', { id: 123 }, { delay: 10000 });

// Run daily
await kernel.queue.enqueue('reports', 'daily', {}, { cron: '0 0 * * *' });

Workers process the queues transparently across all connected JSONExpress instances:

kernel.queue.registerWorker('emails', async (job) => {
    console.log(`Sending email to ${job.payload.to}`);
});