5.43.1 β€’ Published 1 year ago

bullmq v5.43.1

Weekly downloads
41,309
License
MIT
Repository
github
Last release
1 year ago

πŸ›  Tutorials

You can find tutorials and news in this blog: https://blog.taskforce.sh/

News πŸš€

🌐 Language agnostic BullMQ

Do you need to work with BullMQ on platforms other than Node.js? If so, check out the BullMQ Proxy

Official FrontEnd

Supercharge your queues with a professional front end:

  • Get a complete overview of all your queues.
  • Inspect jobs, search, retry, or promote delayed jobs.
  • Metrics and statistics.
  • and many more features.

Sign up at Taskforce.sh

πŸš€ Sponsors πŸš€

Used by

Some notable organizations using BullMQ:

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, failedReason }: { jobId: string; failedReason: string }) => {
    console.error('error painting', failedReason);
  },
);

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

Feature Comparison

Since there are a few job queue solutions, here is a table comparing them:

FeatureBullMQ-ProBullMQBullKueBeeAgenda
Backendredisredisredisredisredismongo
Observablesβœ“
Group Rate Limitβœ“
Group Supportβœ“
Batches Supportβœ“
Parent/Child Dependenciesβœ“βœ“
Debouncingβœ“βœ“βœ“
Prioritiesβœ“βœ“βœ“βœ“βœ“
Concurrencyβœ“βœ“βœ“βœ“βœ“βœ“
Delayed jobsβœ“βœ“βœ“βœ“βœ“
Global eventsβœ“βœ“βœ“βœ“
Rate Limiterβœ“βœ“βœ“
Pause/Resumeβœ“βœ“βœ“βœ“
Sandboxed workerβœ“βœ“βœ“
Repeatable jobsβœ“βœ“βœ“βœ“
Atomic opsβœ“βœ“βœ“βœ“
Persistenceβœ“βœ“βœ“βœ“βœ“βœ“
UIβœ“βœ“βœ“βœ“βœ“
Optimized forJobs / MessagesJobs / MessagesJobs / MessagesJobsMessagesJobs

Contributing

Fork the repo, make some changes, submit a pull-request! Here is the contributing doc that has more details.

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.

@apecommerce/ape-framework@ape-framework/server@rosejs/api@rosejs/workerappistmoleculer-bulmqmedicare-apiahun-payment-gatewaycompass-eth-dbbullmq-supportoox-quotation-cn@phantomauto/redis-tasks@srclaunch/queuesmi-crawl-systempdq-coreevolutty@sxzn/midway-tasknocodb-daily@everything-registry/sub-chunk-1274@zzstack/queuetbs-cron-queuetaskforce-connectortaskforce-connector-invincibleswhiteqwait-youwallflowwildducksuperrequestablesuperreactivetelegram-broadcasterstarter-mern-backend-pack@tanphat199/lb-infrajo-schedulekawkabl-other-datahypersign-mail-client-nestheets-corelucentsdblucentsdb-dailyloopback-connector-bullmqmaegashiraloopback-bulllog-vaultkubitmedusa-plugin-printfulmedusa-plugin-printful-v2@wechatferryxxx/robot@wechatferry/robot@wcfpeter/robot@vucod/email@vendit-dev/event-store-client@verful/adonis-yabq@wangshijun/order-queue-redis@wormhole-foundation/relayer-engine@ultronswap-wormhole/relayer-engine@tlukastee/event-bus-redis@tlukastee/medusa@ucibar/medusa@tuberia/bullmq@uniplanet-lib/common@teleflow/application-generic@traverse-medusa/event-bus-redis@thalesog/adonis-bull@waapi/multiverse@visi/web-server@zakodium/bull-queue@ynikolenko/medusa@yuu2lee4/egg-bullmq@zachtirosh/audit_trail@zemble/bull@terra/mqalemonjs-xianyu@zyws-midway/taskadonis5-bullmqadonisjs-jobsadonis-jobsai-svcali_rear_endasync-prisma-queueasync-operation-queueapeframeworkassumendasolutafooqueuefunpigalaga-typesgcb-bullmqelysia-bullegg-bullmqegg-ts-bullmqequipableevs-toolsexpreso-devethernal-lightexodus-frameworkevent-bus-redis-xponentialevent-bus-mskexpress-typescript-bullmqexpress-soketifeathers-bullmq-transportflowise
5.42.0

1 year ago

5.43.0

1 year ago

5.43.1

1 year ago

5.41.9

1 year ago

5.41.8

1 year ago

5.41.6

1 year ago

5.41.7

1 year ago

5.41.4

1 year ago

5.41.5

1 year ago

5.41.3

1 year ago

5.40.5

1 year ago

5.40.3

1 year ago

5.40.4

1 year ago

5.41.2

1 year ago

5.41.0

1 year ago

5.41.1

1 year ago

5.40.1

1 year ago

5.40.2

1 year ago

5.40.0

1 year ago

5.39.1

1 year ago

5.39.2

1 year ago

5.39.0

1 year ago

5.38.0

1 year ago

5.35.1

1 year ago

5.35.0

1 year ago

5.36.0

1 year ago

5.37.0

1 year ago

5.34.9

1 year ago

5.34.10

1 year ago

5.34.8

1 year ago

5.34.7

1 year ago

5.34.6

1 year ago

5.34.5

1 year ago

5.34.4

1 year ago

5.34.3

1 year ago

5.34.2

1 year ago

5.34.0

1 year ago

5.34.1

1 year ago

5.32.0

1 year ago

5.33.1

1 year ago

5.33.0

1 year ago

5.31.2

1 year ago

5.31.1

1 year ago

5.31.0

1 year ago

5.30.1

1 year ago

5.30.0

1 year ago

5.28.2

1 year ago

5.28.1

1 year ago

5.28.0

1 year ago

5.29.1

1 year ago

5.29.0

1 year ago

5.27.0

1 year ago

5.26.2

1 year ago

5.26.1

1 year ago

5.26.0

1 year ago

5.23.1

1 year ago

5.24.0

1 year ago

5.25.6

1 year ago

5.25.5

1 year ago

5.25.4

1 year ago

5.25.3

1 year ago

5.25.2

1 year ago

5.25.1

1 year ago

5.25.0

1 year ago

5.23.0

1 year ago

5.22.0

1 year ago

3.16.2

1 year ago

4.18.2

1 year ago

5.21.2

1 year ago

5.20.1

1 year ago

5.21.1

1 year ago

5.21.0

1 year ago

3.16.1

1 year ago

4.18.1

1 year ago

3.16.0

1 year ago

5.20.0

1 year ago

5.15.0

1 year ago

5.16.0

1 year ago

5.17.1

1 year ago

5.17.0

1 year ago

5.18.0

1 year ago

5.19.1

1 year ago

5.19.0

1 year ago

4.18.0

1 year ago

5.14.0

2 years ago

5.12.15

2 years ago

5.12.11

2 years ago

5.12.12

2 years ago

5.12.13

2 years ago

5.12.14

2 years ago

5.13.2

2 years ago

5.13.1

2 years ago

5.13.0

2 years ago

5.12.10

2 years ago

5.12.9

2 years ago

5.12.8

2 years ago

5.12.7

2 years ago

5.12.6

2 years ago

5.12.5

2 years ago

5.12.4

2 years ago

5.12.3

2 years ago

5.12.2

2 years ago

5.12.1

2 years ago

5.12.0

2 years ago

5.11.0

2 years ago

5.10.4

2 years ago

5.10.3

2 years ago

5.10.2

2 years ago

5.10.1

2 years ago

5.10.0

2 years ago

5.8.7

2 years ago

5.8.6

2 years ago

5.8.5

2 years ago

5.8.4

2 years ago

5.8.3

2 years ago

5.9.0

2 years ago

5.8.2

2 years ago

5.8.1

2 years ago

5.8.0

2 years ago

5.7.15

2 years ago

5.7.12

2 years ago

5.7.11

2 years ago

5.7.14

2 years ago

5.7.13

2 years ago

5.7.10

2 years ago

5.7.9

2 years ago

5.7.8

2 years ago

5.7.7

2 years ago

5.7.6

2 years ago

5.7.5

2 years ago

5.7.4

2 years ago

5.7.3

2 years ago

5.7.2

2 years ago

5.7.1

2 years ago

5.7.0

2 years ago

5.6.0

2 years ago

5.5.4

2 years ago

5.5.3

2 years ago

5.5.2

2 years ago

5.5.1

2 years ago

5.5.0

2 years ago

5.4.6

2 years ago

5.4.5

2 years ago

5.4.4

2 years ago

5.4.3

2 years ago

5.4.2

2 years ago

5.4.1

2 years ago

5.4.0

2 years ago

5.3.3

2 years ago

5.3.2

2 years ago

5.3.1

2 years ago

5.3.0

2 years ago

5.2.1

2 years ago

5.2.0

2 years ago

5.1.12

2 years ago

5.1.11

2 years ago

5.1.10

2 years ago

5.1.9

2 years ago

5.1.8

2 years ago

5.1.7

2 years ago

5.1.6

2 years ago

5.1.5

2 years ago

5.1.4

2 years ago

5.1.3

2 years ago

5.1.2

2 years ago

5.1.1

2 years ago

5.1.0

2 years ago

5.0.0

2 years ago

4.17.0

2 years ago

4.16.0

2 years ago

4.15.4

2 years ago

4.15.3

2 years ago

4.15.2

2 years ago

4.15.1

2 years ago

4.15.0

2 years ago

4.14.1

2 years ago

4.14.2

2 years ago

4.14.3

2 years ago

4.14.4

2 years ago

4.14.0

2 years ago

4.13.2

2 years ago

4.13.3

2 years ago

4.13.0

2 years ago

4.13.1

2 years ago

4.12.10

2 years ago

4.4.0

3 years ago

4.10.0

3 years ago

4.3.0

3 years ago

4.12.7

2 years ago

4.12.8

2 years ago

4.12.9

2 years ago

4.12.3

2 years ago

4.12.4

2 years ago

4.12.5

2 years ago

4.12.6

2 years ago

4.2.1

3 years ago

4.12.0

3 years ago

4.12.1

2 years ago

4.12.2

2 years ago

4.11.4

3 years ago

4.11.0

3 years ago

4.11.1

3 years ago

4.11.2

3 years ago

4.11.3

3 years ago

4.9.0

3 years ago

4.8.0

3 years ago

4.7.0

3 years ago

4.7.2

3 years ago

4.7.1

3 years ago

4.7.4

3 years ago

4.7.3

3 years ago

4.6.0

3 years ago

4.6.3

3 years ago

4.6.2

3 years ago

4.5.0

3 years ago

4.2.0

3 years ago

4.0.0

3 years ago

3.15.8

3 years ago

3.15.7

3 years ago

3.15.6

3 years ago

3.15.5

3 years ago

4.1.0

3 years ago

3.14.1

3 years ago

3.14.0

3 years ago

3.14.2

3 years ago

3.15.0

3 years ago

3.15.2

3 years ago

3.15.1

3 years ago

3.15.4

3 years ago

3.15.3

3 years ago

3.13.2

3 years ago

3.13.1

3 years ago

3.13.4

3 years ago

3.13.3

3 years ago

3.12.1

3 years ago

3.12.0

3 years ago

3.13.0

3 years ago

3.11.0

3 years ago

3.10.3

3 years ago

3.10.4

3 years ago

3.9.0

3 years ago

3.10.1

3 years ago

3.8.0

3 years ago

3.10.0

3 years ago

3.10.2

3 years ago

3.7.2

3 years ago

3.7.1

3 years ago

3.7.0

3 years ago

3.6.6

3 years ago

3.6.2

3 years ago

3.6.5

3 years ago

3.6.4

3 years ago

3.6.3

3 years ago

3.5.11

3 years ago

3.5.10

3 years ago

3.6.1

3 years ago

3.6.0

3 years ago

3.5.3

3 years ago

3.5.2

3 years ago

3.5.1

3 years ago

3.5.0

3 years ago

3.5.7

3 years ago

3.5.6

3 years ago

3.5.5

3 years ago

3.5.4

3 years ago

3.5.9

3 years ago

3.5.8

3 years ago

3.4.0

3 years ago

3.4.2

3 years ago

3.4.1

3 years ago

3.3.1

3 years ago

3.3.0

3 years ago

3.3.5

3 years ago

3.3.4

3 years ago

3.3.3

3 years ago

3.3.2

3 years ago

2.4.0

3 years ago

3.2.2

3 years ago

3.2.1

3 years ago

3.2.0

3 years ago

3.2.5

3 years ago

3.2.4

3 years ago

3.2.3

3 years ago

2.3.0

3 years ago

2.3.2

3 years ago

2.3.1

3 years ago

3.1.3

3 years ago

3.1.2

3 years ago

3.1.1

3 years ago

3.1.0

3 years ago

2.2.1

3 years ago

2.2.0

3 years ago

3.0.1

3 years ago

3.0.0

3 years ago

2.1.2

4 years ago

2.1.1

4 years ago

2.1.3

4 years ago

2.1.0

4 years ago

1.90.2

4 years ago

2.0.2

4 years ago

2.0.1

4 years ago

2.0.0

4 years ago

1.91.1

4 years ago

1.91.0

4 years ago

1.90.1

4 years ago

1.90.0

4 years ago

1.86.2

4 years ago

1.86.3

4 years ago

1.86.4

4 years ago

1.86.5

4 years ago

1.86.6

4 years ago

1.86.7

4 years ago

1.86.8

4 years ago

1.86.9

4 years ago

1.86.10

4 years ago

1.87.0

4 years ago

1.87.1

4 years ago

1.87.2

4 years ago

1.89.2

4 years ago

1.89.1

4 years ago

1.89.0

4 years ago

1.88.0

4 years ago

1.88.1

4 years ago

1.88.2

4 years ago

1.82.0

4 years ago

1.82.1

4 years ago

1.82.2

4 years ago

1.82.3

4 years ago

1.83.0

4 years ago

1.83.1

4 years ago

1.83.2

4 years ago

1.84.0

4 years ago

1.84.1

4 years ago

1.85.0

4 years ago

1.85.1

4 years ago

1.85.2

4 years ago

1.85.3

4 years ago

1.85.4

4 years ago

1.86.0

4 years ago

1.86.1

4 years ago

1.81.4

4 years ago

1.80.1

4 years ago

1.80.2

4 years ago

1.80.3

4 years ago

1.80.4

4 years ago

1.80.5

4 years ago

1.80.6

4 years ago

1.81.0

4 years ago

1.81.1

4 years ago

1.81.2

4 years ago

1.81.3

4 years ago

1.79.0

4 years ago

1.79.1

4 years ago

1.76.2

4 years ago

1.76.3

4 years ago

1.76.4

4 years ago

1.76.5

4 years ago

1.76.6

4 years ago

1.77.1

4 years ago

1.77.2

4 years ago

1.77.3

4 years ago

1.80.0

4 years ago

1.78.0

4 years ago

1.78.1

4 years ago

1.78.2

4 years ago

1.77.0

4 years ago

1.74.3

4 years ago

1.75.0

4 years ago

1.75.1

4 years ago

1.76.0

4 years ago

1.76.1

4 years ago

1.56.0

4 years ago

1.67.0

4 years ago

1.67.1

4 years ago

1.67.2

4 years ago

1.67.3

4 years ago

1.70.0

4 years ago

1.55.0

4 years ago

1.57.0

4 years ago

1.57.2

4 years ago

1.57.1

4 years ago

1.57.4

4 years ago

1.57.3

4 years ago

1.60.0

4 years ago

1.68.0

4 years ago

1.68.1

4 years ago

1.68.2

4 years ago

1.68.3

4 years ago

1.68.4

4 years ago

1.71.0

4 years ago

1.58.0

4 years ago

1.61.0

4 years ago

1.69.0

4 years ago

1.69.1

4 years ago

1.72.0

4 years ago

1.59.0

4 years ago

1.59.2

4 years ago

1.59.1

4 years ago

1.59.4

4 years ago

1.59.3

4 years ago

1.62.0

4 years ago

1.73.0

4 years ago

1.63.0

4 years ago

1.63.1

4 years ago

1.63.2

4 years ago

1.63.3

4 years ago

1.74.0

4 years ago

1.74.1

4 years ago

1.74.2

4 years ago

1.64.0

4 years ago

1.64.1

4 years ago

1.64.2

4 years ago

1.64.3

4 years ago

1.64.4

4 years ago

1.54.6

4 years ago

1.65.0

4 years ago

1.65.1

4 years ago

1.55.1

4 years ago

1.66.0

4 years ago

1.66.1

4 years ago

1.51.2

4 years ago

1.51.3

4 years ago

1.52.1

4 years ago

1.52.0

4 years ago

1.52.2

4 years ago

1.54.3

4 years ago

1.54.2

4 years ago

1.54.5

4 years ago

1.54.4

4 years ago

1.53.0

4 years ago

1.54.1

4 years ago

1.54.0

4 years ago

1.51.0

4 years ago

1.51.1

4 years ago

1.50.7

4 years ago

1.50.6

4 years ago

1.50.1

4 years ago

1.50.0

4 years ago

1.50.3

4 years ago

1.50.2

4 years ago

1.50.5

4 years ago

1.50.4

4 years ago

1.48.3

4 years ago

1.49.0

4 years ago

1.48.2

5 years ago

1.48.0

5 years ago

1.48.1

5 years ago

1.47.2

5 years ago

1.46.7

5 years ago

1.47.1

5 years ago

1.47.0

5 years ago

1.46.6

5 years ago

1.46.5

5 years ago

1.46.4

5 years ago

1.46.3

5 years ago

1.46.2

5 years ago

1.46.1

5 years ago

1.46.0

5 years ago

1.44.3

5 years ago

1.45.0

5 years ago

1.44.2

5 years ago

1.44.0

5 years ago

1.44.1

5 years ago

1.43.0

5 years ago

1.42.1

5 years ago

1.41.0

5 years ago

1.42.0

5 years ago

1.40.2

5 years ago

1.40.4

5 years ago

1.40.3

5 years ago

1.40.1

5 years ago

1.40.0

5 years ago

1.39.5

5 years ago

1.39.4

5 years ago

1.39.3

5 years ago

1.39.1

5 years ago

1.39.2

5 years ago

1.39.0

5 years ago

1.38.0

5 years ago

1.38.1

5 years ago

1.37.1

5 years ago

1.37.0

5 years ago

1.36.1

5 years ago

1.36.0

5 years ago

1.35.0

5 years ago

1.34.2

5 years ago

1.34.0

5 years ago

1.34.1

5 years ago

1.33.1

5 years ago

1.33.0

5 years ago

1.32.0

5 years ago

1.31.1

5 years ago

1.31.0

5 years ago

1.30.2

5 years ago

1.30.0

5 years ago

1.30.1

5 years ago

1.29.1

5 years ago

1.29.0

5 years ago

1.28.2

5 years ago

1.28.1

5 years ago

1.27.0

5 years ago

1.28.0

5 years ago

1.26.5

5 years ago

1.26.4

5 years ago

1.26.3

5 years ago

1.26.2

5 years ago

1.26.1

5 years ago

1.25.2

5 years ago

1.26.0

5 years ago

1.25.1

5 years ago

1.25.0

5 years ago

1.24.5

5 years ago

1.24.4

5 years ago

1.24.3

5 years ago

1.24.2

5 years ago

1.24.1

5 years ago

1.24.0

5 years ago

1.23.1

5 years ago

1.23.0

5 years ago

1.22.2

5 years ago

1.22.1

5 years ago

1.22.0

5 years ago

1.21.0

5 years ago

1.20.6

5 years ago

1.20.5

5 years ago

1.20.4

5 years ago

1.20.3

5 years ago

1.20.2

5 years ago

1.20.1

5 years ago

1.20.0

5 years ago

1.19.3

5 years ago

1.19.2

5 years ago

1.19.0

5 years ago

1.19.1

5 years ago

1.18.1

5 years ago

1.18.0

5 years ago

1.18.2

5 years ago

1.17.0

5 years ago

1.16.2

5 years ago

1.16.1

5 years ago

1.16.0

5 years ago

1.15.0

5 years ago

1.15.1

5 years ago

1.14.8

5 years ago

1.14.5

5 years ago

1.14.7

5 years ago

1.14.6

5 years ago

1.14.4

5 years ago

1.14.3

5 years ago

1.14.1

5 years ago

1.14.2

5 years ago

1.14.0

5 years ago

1.13.0

5 years ago

1.12.3

5 years ago

1.12.2

5 years ago

1.12.1

5 years ago

1.11.2

5 years ago

1.12.0

5 years ago

1.11.1

5 years ago

1.11.0

5 years ago

1.10.0

5 years ago

1.9.0

6 years ago

1.8.14

6 years ago

1.8.13

6 years ago

1.8.12

6 years ago

1.8.11

6 years ago

1.8.10

6 years ago

1.8.9

6 years ago

1.8.8

6 years ago

1.8.7

6 years ago

1.8.6

6 years ago

1.8.5

6 years ago

1.8.4

6 years ago

1.8.3

6 years ago

1.8.2

6 years ago

1.8.1

6 years ago

1.8.0

6 years ago

1.7.0

6 years ago

1.6.8

6 years ago

1.6.7

6 years ago

1.6.4

6 years ago

1.6.6

6 years ago

1.6.5

6 years ago

1.6.3

6 years ago

1.6.2

6 years ago

1.6.1

6 years ago

1.6.0

6 years ago

1.5.0

6 years ago

1.4.3

6 years ago

1.4.2

6 years ago

1.4.1

6 years ago

1.4.0

6 years ago

1.3.0

6 years ago

1.2.0

6 years ago

1.1.0

6 years ago

1.0.1

6 years ago

4.0.0-beta.2

6 years ago

4.0.0-beta.1

6 years ago

4.0.0-beta.0

7 years ago

0.0.1

11 years ago