Hanzo MQ
Distributed message queue
BullMQ-compatible job queue with scheduling, rate limiting, priorities, retries, and dead letter queues. Backed by Hanzo KV for durability.
Job Processing at Scale
Reliable background job processing for any workload.
Scheduling
Cron expressions, delayed jobs, and repeatable tasks. Timezone-aware scheduling.
Rate Limiting
Per-queue and global rate limits. Concurrency controls. Prevent resource exhaustion.
Priority Queues
Multiple priority levels. Critical jobs jump the line. FIFO within same priority.
Retry & Backoff
Configurable retry strategies with exponential backoff. Custom retry delays per attempt.
Dashboard
Web UI to monitor queues, inspect jobs, retry failed jobs, and view throughput metrics.
Dead Letter Queue
Failed jobs move to DLQ after max retries. Inspect, debug, and replay manually.
BullMQ-Compatible API
import { Queue, Worker } from "bullmq"
const queue = new Queue("emails", {
connection: { host: "mq.hanzo.ai", port: 6379 }
})
// Add jobs with options
await queue.add("welcome", { userId: "usr_123" }, {
priority: 1,
delay: 5000,
attempts: 3,
backoff: { type: "exponential", delay: 1000 },
})
// Process jobs
const worker = new Worker("emails", async (job) => {
await sendEmail(job.data.userId, "welcome")
}, {
connection: { host: "mq.hanzo.ai", port: 6379 },
concurrency: 10,
limiter: { max: 100, duration: 60_000 },
})25% of compute goes back to open source
Every deployment is SBOM-verified. Contributors to BullMQ earn a share of compute revenue — transparent, on-chain, and customizable by the community.
25% of compute goes back to OSS authors
Every Hanzo deployment tracks software dependencies via SBOM. When your code powers compute on Hanzo, the authors get paid — automatically.
Process Jobs Reliably
Free tier includes 10K jobs/month. No job size limits.