Overview

What is BullMQ
Quick Start
API Reference
Changelogs
- v5
  v4
  v3
  v2
  v1

Guide

Introduction
Connections
PostgreSQL backend
Queues
- Auto-removal of jobs
  Adding jobs in bulk
  Working with batches
  Global Concurrency
  Global Rate Limit
  Meta
  Removing Jobs
Workers
- Auto-removal of jobs
  Concurrency
  Graceful shutdown
  Cancelling jobs
  Stalled Jobs
  Sandboxed processors
  Pausing queues
Jobs
- FIFO
  LIFO
  Job Ids
  Job Data
  Deduplication
  Delayed
  Repeatable
  Prioritized
  Removing jobs
  Retrying jobs
  Stalled
  Getters
Job Schedulers
- Repeat Strategies
  Repeat options
  Manage Job Schedulers
Flows
- Adding flows in bulk
  Get Flow Tree
  Fail Parent
  Continue Parent
  Remove Dependency
  Ignore Dependency
  Remove Child Dependency
Metrics
- Prometheus
Rate limiting
Parallelism and Concurrency
Retrying failing jobs
Returning job data
Events
- Create Custom Events
Relay
- Getting started
  Topics and patterns
  Publishing and subscribing
  Retained messages
  Nodes and failures
  Backends
  Reference
  Relay compared to Kafka
  Example: Live job progress
  Example: Real-time notifications
  Example: Cache invalidation
  Example: Live configuration
  Example: Controlling workers
  Example: Cancelling jobs on other workers
Telemetry
- Getting started
  Traces
  Metrics
  Running Jaeger
  Running a simple example
QueueScheduler
Redis™ Compatibility
- Dragonfly
Redis™ hosting
- AWS MemoryDB
  AWS Elasticache
Architecture
NestJs
- Producers
  Queue Events Listeners
Going to production
Migrations
- Bull to BullMQ
  Migrate from v5 to v6
Troubleshooting

Patterns

Adding jobs in bulk across different queues
Deduplication
Manually processing jobs
Named Processor
Flows
Idempotent jobs
Throttle jobs
Manual retrying
Process Step Jobs
Failing fast when Redis is down
Stop retrying jobs
Timeout jobs
Timeout for Sandboxed processors
Redis Cluster

BullMQ Pro

Introduction
Install
Observables
- Cancelation
Groups
- Getters
  Rate limiting
  Local group rate limit
  Concurrency
  Local group concurrency
  Max group size
  Pausing groups
  Prioritized intra-groups
  Sandboxes for groups
Telemetry
Batches
NestJs
- Producers
  Queue Events Listeners
  API Reference
  Changelog
API Reference
Changelogs
- v6
  v5
  v4
  v3
  v2
  v1
New Releases
Support

Bull

Introduction
Install
Quick Guide
Important Notes
Reference
Patterns
- Persistent connections
  Message queue
  Returning Job Completions
  Reusing Redis Connections
  Redis cluster
  Custom backoff strategy
  Debugging
  Manually fetching jobs

Python

Introduction
Flow Producer
Job Scheduler
Lock Manager
Global Concurrency and Rate Limit
Job Cancellation
Queue Events
Changelogs
- v2
  v1
  v0

Rust

Introduction
API Reference
Changelogs

Elixir

Introduction
API Reference
Changelogs
- v1

PHP

Introduction
Changelogs
- v1

.Net

Introduction
Changelogs

On this page

Redis™ hosting

Edit this page on GitHub

Last updated:

Pager

Previous pageDragonfly

Next pageAWS MemoryDB

Released under the MIT License.

Redis™ hosting ​

Redis™ hosting