bullmq-lite
TypeScript icon, indicating that this package has built-in type declarations

1.8.4 • Public • Published



The fastest, most reliable, Redis-based distributed queue for Node.
Carefully written for rock solid stability and atomicity.

Read the documentation

Follow @manast for Bull news and updates!

The gist

Install:

$ yarn add bullmq

Add jobs to the queue:

import { Queue } from 'bullmq';
 
const queue = new Queue('Paint');
 
queue.add('cars', { color: 'blue' });

Process the jobs in your workers:

import { Worker } from 'bullmq';
 
const worker = new Worker('Paint', async job => {
  if (job.name === 'cars') {
    await paintCar(job.data.color);
  }
});

Listen to jobs for completion:

import { QueueEvents } from 'bullmq';
 
const queueEvents = new QueueEvents('Paint');
 
queueEvents.on('completed', jobId => {
  console.log('done painting');
});
 
queueEvents.on('failed', (jobId, err) => {
  console.error('error painting', err);
});

This is just scratching the surface, check all the features and more in the official documentation

Thanks

Thanks for all the contributors that made this library possible, also a special mention to Leon van Kammen that kindly donated his npm bullmq repo.

Readme

Keywords

none

Package Sidebar

Install

npm i bullmq-lite

Weekly Downloads

26

Version

1.8.4

License

MIT

Unpacked Size

1.01 MB

Total Files

287

Last publish

Collaborators

  • wenq1