Blazing Fast
10M+ jobs/hour on a single machine. Built on Bun’s native SQLite with WAL mode for maximum throughput.
Blazing Fast
10M+ jobs/hour on a single machine. Built on Bun’s native SQLite with WAL mode for maximum throughput.
Zero Dependencies
No Redis, no external services. Just Bun and SQLite. Deploy anywhere in seconds.
Production Ready
Stall detection, dead letter queues, automatic retries, rate limiting, and S3 backups built-in.
BullMQ Compatible
Familiar API for easy migration. Drop-in replacement for most BullMQ use cases.
import { Queue, Worker } from 'bunqueue/client';
// Create a queueconst queue = new Queue('emails');
// Add jobsawait queue.add('welcome', { to: 'user@example.com', template: 'welcome'});
// Process jobsconst worker = new Worker('emails', async (job) => { await sendEmail(job.data); return { sent: true };});
worker.on('completed', (job) => console.log(`✓ ${job.id}`));# Start the serverbunqueue start --data-path ./data/queue.db
# Push a jobbunqueue push emails '{"to":"user@test.com"}' --priority 10
# Pull and processbunqueue pull emailsbunqueue ack <job-id>FROM oven/bun:latestWORKDIR /appRUN bun add bunqueueCOPY . .CMD ["bunqueue", "start"]docker run -p 6789:6789 -p 6790:6790 \ -v ./data:/app/data \ -e DATA_PATH=/app/data/queue.db \ bunqueueMeasured on Mac Studio M1 Max, 32GB RAM. Run bun run bench for your hardware.
50-150K ops/sec
Push throughput with batch operations
< 1ms p99
Sub-millisecond latency
~50MB base
Minimal memory footprint
< 100ms
Cold start time
Priority Queues
Process high-priority jobs first with configurable priority levels.
Delayed Jobs
Schedule jobs to run at a specific time or after a delay.
Retries & Backoff
Automatic retries with exponential backoff on failure.
Rate Limiting
Control job processing rate per queue or globally.
Stall Detection
Automatic recovery of jobs that become unresponsive.
Dead Letter Queue
Advanced DLQ with metadata, filtering, and auto-retry.
Cron Jobs
Schedule recurring jobs with cron expressions or intervals.
Parent-Child Flows
Create job hierarchies with dependencies.
Progress Tracking
Real-time progress updates and job logs.
Webhooks
HTTP callbacks for job events.
S3 Backup
Automated backups to any S3-compatible storage.
Prometheus Metrics
Built-in metrics endpoint for monitoring.