README
💡 Note: You are viewing the
nextbranch with upcoming features. For stable releases, check themasterbranch.
A high-performance Redis message queue for Node.js — simple to use, built for scale.
✨ Features
- 📬 Reliable delivery with retries
- 📊 Multiple queue types: FIFO, LIFO, Priority
- 🔀 Flexible routing: Direct/Topic/Fanout exchanges + Direct queue publishing
- 👥 Pub/Sub & Point-to-Point delivery models with native consumer groups
- 🚦 Queue-level rate limiting
- ⏰ Built-in scheduler: delays, CRON, repeating
- 🔒 Queue state management: pause/stop/resume + audit
- ⏱️ Message TTL & consumption timeouts
- 🚀 High-throughput design with atomic Lua scripts
- 📦 Batch acks & Batch unacks — 99% fewer Redis calls
- 🧵 Worker threads for CPU-heavy handlers
- 🔄 Multi-queue producers & consumers with multiplexing support
- 📡 Event bus for real-time internal events
- 🌐 REST API with OpenAPI + Swagger
- 📊 Web UI for live management
- 🎯 Process-wide API — initialize once, factory methods, single shutdown
- 🔄 Dual callback & promise support
- 📦 ESM + CJS module support