BullMQ

Strapi Plugin BullMQ is a plugin that integrates Bull Queue with Strapi, providing robust job queue management capabilities for your Strapi applications.

Install now

strapi-plugin-bullmq

Strapi Plugin BullMQ is a plugin that integrates BullMQ with Strapi, providing robust job queue management capabilities for your Strapi applications.

✅ Requirements

Strapi v5
@strapi-community/plugin-redis

🔧 Installation

Install the required Redis plugin & BullMQ plugin:

npm install @strapi-community/plugin-redis strapi-plugin-bullmq

yarn add @strapi-community/plugin-redis strapi-plugin-bullmq

pnpm add @strapi-community/plugin-redis strapi-plugin-bullmq

For more details, see: https://strapi-community.github.io/plugin-redis

Configure the Redis connection for BullMQ in your config/plugins.js or config/plugins.ts:

module.exports = {
  // ...
  redis: {
    enabled: true,
    config: {
      connections: {
        // ...
        queue: {
          connection: {
            host: env('REDIS_HOST', '127.0.0.1'),
            port: env('REDIS_PORT', 6379),
            password: env('REDIS_PASSWORD'),
            username: env('REDIS_USERNAME', 'default'),
            maxRetriesPerRequest: null,
          },
        },
      },
    },
  },
  // ...
};

Note: maxRetriesPerRequest must be set to null for persistent connections. For more details, see: https://docs.bullmq.io/bull/patterns/persistent-connections

Configure the plugin in your config/plugins.js or config/plugins.ts:

module.exports = {
  // ...
  bullmq: {
    enabled: true,
    config: {
      connectionName: 'queue', // Name of the Redis connection to use
    },
  },
  // ...
};

Note: connectionName must be the same as the name of the Redis connection configured in the previous step.

📖 Usage

Creating a Queue

const queue = strapi.plugin('bullmq').service('queue').get('my-queue');

Adding Jobs to a Queue

await queue.add('job-name', { data: 'some data' });

Creating a Worker

const worker = strapi
  .plugin('bullmq')
  .service('worker')
  .create(queue, async (job) => {
    console.log('Processing job:', job.name, job.data);
    // Process the job
  });

Recommendation: It is recommended to create and start workers in your bootstrap.ts or bootstrap.js file to ensure they are initialized when the Strapi application starts.

Note: The plugin automatically handles connection cleanup when the Strapi destroy event is fired, so manual cleanup is not required.

Job Options

You can pass options when adding jobs:

await queue.add(
  'job-name',
  { data: 'some data' },
  {
    delay: 5000, // Delay in milliseconds
    priority: 1, // Priority (higher numbers have higher priority)
    attempts: 3, // Number of attempts
  }
);

For more details, see: https://docs.bullmq.io/guide/queues

Worker Options

const worker = strapi
  .plugin('bullmq')
  .service('worker')
  .create(queue, handler, {
    concurrency: 5, // Number of concurrent jobs
    limiter: { max: 10, duration: 1000 }, // Rate limiting
  });