BullMQ

Redis-backed job queue: enqueue jobs, track progress, and process queues

BullMQ API referenceAPI checked August 18, 2026

Signs in with: Connection details
Runs on: Cloud or On-Prem Worker
Operations: 57
Ready-made triggers: 0

Connect BullMQ

In Neblex open Connect › Connections and click New Connection.
Search for BullMQ and give the connection a clear name.
Fill in the fields. Secret values are encrypted and never shown again.
Click Test, then Create Connection.

If the system is only reachable inside your network, choose an On-Prem Worker under Test from and run the flow on that Worker. See On-Prem Workers.

Field	What to enter
Connection setupRequired
HostRequired
PortOptional	Example: `6379`
Database numberOptional
UsernameOptional
PasswordOptionalSecret
Use TLSOptional	Turning this off sends traffic and credentials without transport encryption. Use plaintext only for a customer-controlled endpoint that explicitly requires it.
Connection stringRequiredSecret	Paste a redis:// or rediss:// connection string.

Use it in a flow

Open a flow, open the node library and search for BullMQ.
Drag it onto the canvas and choose an Operation and your connection.
Map the operation's fields from earlier steps, or click Map with Matt.
Use Test this step to see what it returns, then save.

To start a flow from BullMQ without a ready-made trigger: a Live stream trigger with BullMQ as the stream source starts a run for each message as it arrives (see Streaming triggers).

Operations

57 operations in 14 groups. Each one is a step you can add to a flow.

Connection1

Test the connectionping Connect through the guarded Redis transport, load BullMQ's commands, and complete a PING round trip.

Jobs · Create2

Add a job`add`		Add one BullMQ job with the complete official job-options model.
Add jobs in bulk`add_bulk`		Add up to 1000 jobs with per-job data and complete options.

Jobs · Data2

Update job data`update_job_data`		Replace one job's JSON data and emit the vendor-compatible update.
Update job progress`update_job_progress`		Update numeric or JSON progress and emit a progress event.

Jobs · Dependencies3

Count dependencies`get_dependencies_count`		Return processed, unprocessed, ignored, and failed child counts.
Get dependencies`get_dependencies`		Scan a bounded page of processed and unprocessed child dependencies.
Remove child dependency`remove_child_dependency`		Atomically detach a child from its fully qualified parent key.

Jobs · Lifecycle6

Change job delay`change_job_delay`		Change the delay of a delayed job.
Change job priority`change_job_priority`		Change priority and same-priority ordering for a waiting job.
Promote a delayed job`promote_job`		Move one delayed job to waiting immediately.
Remove a job`remove_job`		Atomically remove an unlocked job and optionally its children.
Remove pending children`remove_unprocessed_children`		Remove a parent's unprocessed children while preserving active children.
Retry one job`retry_job`		Move a completed or failed job back to waiting with optional attempt-counter resets.

Jobs · Logs3

Add a job log row`add_job_log`		Append a log row and return the total row count.
Clear job logs`clear_job_logs`		Delete all logs or retain the newest requested count.
Get job logs`get_job_logs`		Return a bounded page of job log rows.

Jobs · Read8

Count processable jobs`count`		Count waiting, paused, delayed, prioritized, and waiting-children jobs.
Get a job`get_job`		Return one complete BullMQ job record by ID.
Get all job counts`get_job_counts`		Return counts for every queue state.
Get counts by priority`get_counts_per_priority`		Return counts for the requested priority values.
Get counts by state`get_job_counts_by_types`		Return counts for selected states; an empty list means every state.
Get job state`get_job_state`		Return the official state of one job.
List job IDs`get_ranges`		Return a bounded page of job IDs across selected states.
List jobs`get_jobs`		Return a bounded page of complete jobs across selected states.

Queue · Control2

Pause queue`pause`		Globally pause dispatch while active jobs finish.
Resume queue`resume`		Globally resume dispatch.

Queue · Deduplication2

Get deduplicated job ID`get_deduplication_job_id`		Resolve a deduplication ID to its current job.
Remove deduplication key`remove_deduplication_key`		Atomically remove a deduplication key only when it still owns the supplied job.

Queue · Limits9

Apply temporary rate limit`rate_limit`		Prevent new jobs from starting until the requested TTL expires.
Get global concurrency`get_global_concurrency`		Return the queue-wide concurrency limit.
Get global rate limit`get_global_rate_limit`		Return the queue-wide rate limit.
Get rate-limit TTL`get_rate_limit_ttl`		Return the remaining rate-limit TTL.
Remove global concurrency`remove_global_concurrency`		Remove the queue-wide concurrency limit.
Remove global rate limit`remove_global_rate_limit`		Remove the queue-wide rate limit.
Remove temporary rate limit`remove_rate_limit`		Remove the current rate-limit key.
Set global concurrency`set_global_concurrency`		Set the maximum active jobs across all workers.
Set global rate limit`set_global_rate_limit`		Set the maximum starts per duration across all workers.

Queue · Maintenance5

Clean old jobs`clean`		Remove a bounded number of jobs older than a grace period from one state.
Drain queue`drain`		Remove waiting jobs and optionally delayed jobs without touching active/history states.
Obliterate queue`obliterate`		Delete every queue key in bounded batches; active jobs require explicit force.
Promote delayed jobs`promote_jobs`		Promote all delayed jobs in bounded batches.
Retry jobs in bulk`retry_jobs`		Move eligible completed or failed jobs back to waiting in bounded batches.

Queue · Observability8

Check global saturation`is_maxed`		Return whether active jobs reached global concurrency.
Count workers`get_workers_count`		Count connected workers discoverable for this queue.
Export Prometheus metrics`export_prometheus_metrics`		Export BullMQ gauges and counters with optional global labels.
Get queue library version`get_version`		Return the library version recorded in queue metadata.
Get queue metadata`get_meta`		Return public queue metadata and preserved vendor fields.
Get time-series metrics`get_metrics`		Return a bounded page of completed or failed counts per minute.
List workers`get_workers`		List connected workers discoverable through Redis client names.
Trim event stream`trim_events`		Approximately trim the queue event stream to a maximum length.

Queue · Status1

Check paused stateis_paused Return whether the queue is globally paused.

Schedulers5

Count job schedulers`get_job_schedulers_count`		Return the number of schedulers.
Get job scheduler`get_job_scheduler`		Return one scheduler by ID.
List job schedulers`get_job_schedulers`		Return a bounded page ordered by next execution time.
Remove job scheduler`remove_job_scheduler`		Remove a scheduler and its next delayed iteration.
Upsert job scheduler`upsert_job_scheduler`		Create or update a cron/every scheduler and its next delayed job.