Monque runs background jobs in Node.js applications using MongoDB. Schedule work, register workers, and let multiple processes share a jobs collection. Add the Management API and Dashboard to inspect jobs and control processing from your application.

Documentation · Getting started · Dashboard setup

Packages

Start with @monque/core. The other packages add framework integration, an HTTP API, or a browser dashboard around the same scheduler.

Package	Use it to
@monque/core	Enqueue jobs, register workers, and manage scheduling and execution.
@monque/tsed	Register workers with Ts.ED decorators and manage the scheduler through dependency injection.
@monque/management	Expose job queries and actions through an HTTP contract with authorization hooks and OpenAPI.
@monque/management-express	Mount the Management API in an Express application.
@monque/dashboard	Use the prebuilt browser dashboard assets in a server integration.
@monque/dashboard-express	Serve the Dashboard from Express without a frontend build.

For Express, mount both @monque/management-express and @monque/dashboard-express. The first exposes your scheduler; the second serves the UI. Protect both with your application's authentication middleware. See the complete setup.

Working with jobs

• Schedule work: enqueue immediately, choose a future date, or use a recurring cron schedule with a timezone. Submit batches with enqueueMany() or include job writes in your own MongoDB transaction.
• Control execution: set worker and instance concurrency, configure retries per worker, and pause or resume local processing without interrupting running jobs.
• Validate payloads: pass a Standard Schema compatible validator to a worker. The handler receives validated output, including schema transformations.
• Recover interrupted work: atomic claims coordinate workers across processes. Optional renewable leases keep long-running jobs claimed and let surviving schedulers recover abandoned work. Change Streams wake workers, with polling as a fallback.
• Inspect and operate: browse jobs and worker policies, inspect failures and lease deadlines, and retry, cancel, reschedule, or delete jobs through the API or Dashboard.

Retries and recovery can run a job more than once. Keep handlers idempotent; claim ownership protects stored job state, but cannot undo a handler's external side effects. Pause and resume controls apply only to the scheduler instance receiving the request.

Quick start

Install core and its MongoDB peer dependency:

bun add @monque/core mongodb

import { Monque } from "@monque/core";
import { MongoClient } from "mongodb";

const client = await MongoClient.connect("mongodb://localhost:27017");
const monque = new Monque(client.db("myapp"));
await monque.initialize();

monque.register<{ message: string }>("log-message", async (job) => {
  console.log(job.data.message);
});
monque.start();

await monque.enqueue("log-message", { message: "Hello from Monque" });

async function shutdown() {
  await monque.stop();
  await client.close();
}

process.once("SIGINT", shutdown);
process.once("SIGTERM", shutdown);

See the guides for scheduling and transactions, workers and validation, retry settings, and renewable leases.

Requirements

• Node.js 22.12 or newer.
• MongoDB 4.4 or newer. Change Streams and transactions require a replica set or sharded cluster. Workers can use polling with a standalone MongoDB server.

Development

Install the Vite+ global CLI and use the versions pinned in package.json and .node-version. Integration tests need Docker for MongoDB Testcontainers.

vp install
vp run check
vp run test
vp run build

vp run test runs the workspace unit and integration tests. To also run the CI-script tests and all Dashboard browser tests, complete the browser-test setup, then run this from the repository root:

vp run test:all

The full suite requires Docker, a running MongoDB instance, and Chromium as described in the setup guide. A failed suite stops the command with an error.

The documentation site lives in apps/docs. Run vp run @monque/docs#dev to work on it locally.

Inspired by

• Agenda and Pulse: MongoDB job scheduling.
• BullMQ: Redis job queues.
• pg-boss and Graphile Worker: PostgreSQL job queues.

License

ISC © Maurice de Bruyn