Queue & Stats
Statistics, dead letters, queue control, and settings.
Statistics, dead letters, queue control, and settings.
| Method | Description |
|---|---|
stats() / statsByQueue(q) / statsAllQueues() | QueueStats counts by status. |
metrics(taskName, sinceMs) → List<TaskMetric> | Per-execution metrics (null task = all). |
| Method | Description |
|---|---|
listDead(limit, offset) / listDeadByTask(task, limit, offset) | Dead-letter entries. |
retryDead(deadId) (alias retry) / deleteDead(deadId) | Re-enqueue / drop an entry. |
purgeDead(olderThanMs) / purgeDeadByTask(task) | Bulk DLQ cleanup → count removed. |
| Method | Description |
|---|---|
requeueJob(jobId) → boolean | Force a stuck running job back to pending, releasing its execution claim. false when the job is missing or isn't running. |
requeueJob() preserves the job's retry budget, but only use it when the
owning worker is confirmed dead or hung: if the old attempt is still running,
it may finish later and the job executes twice. See
troubleshooting.
| Method | Description |
|---|---|
queue(name) → Queue | A named-queue handle: name(), pause(), resume(), isPaused(). |
listPausedQueues() | Names of every paused queue. |
| Method | Description |
|---|---|
getSetting / setSetting / deleteSetting / listSettings | Shared key–value settings in the store. |
| Method | Description |
|---|---|
purgeCompleted(olderThanMs) | Drop old completed jobs. |