OmniQueue

One API – every queue.

Ship messages through RabbitMQ, AWS SQS, Azure Service Bus, ActiveMQ, Kafka, and NATS / JetStream without changing a line of business code.

✨ Magic Add-ons 🔄 Delays ⏰ DLQ Time-travel 🔍 Tracing 🛡️ Idempotency

🛠️ Quick Install

npm i @omniqueue/core @omniqueue/rabbitmq amqplib
npm i @omniqueue/core @omniqueue/kafka @omniqueue/kafka-kafkajs kafkajs
npm i @omniqueue/core @omniqueue/nats @omniqueue/nats-natsjs nats

Adapters use peer dependencies—install only what you need, nothing else is downloaded or bundled.

🔹 Unified Interface

Single Broker interface with send, receive, explicit ack()/nack()

Queue autoprovisioning (streams / topics / queues)

Type-safe payloads, pluggable serializers

Tiny core (<10 kB)

✨ Magic Add-ons

later() – cross-broker delayed messages

Time-travel DLQ replay

OpenTelemetry auto-trace

Idempotent consumer decorator

Zero-Drop outbox for exactly-once publish

🚀 Quick Start

import { create } from "@omniqueue/core";
import "@omniqueue/rabbitmq";

const mq = await create("rabbitmq", { url: "amqp://localhost" });
await mq.send("tasks", { body: { id: 1 } });
await mq.receive("tasks", async msg => {
  console.log("got", msg.body);
  await msg.ack();
});

📦 Supported Adapters

Package Broker Notes
@omniqueue/rabbitmq RabbitMQ needs amqplib
@omniqueue/sqs AWS SQS (Standard + FIFO) modular AWS SDK v3
@omniqueue/azuresb Azure Service Bus queues, topics, sessions
@omniqueue/activemq ActiveMQ (Artemis / Classic) STOMP
@omniqueue/kafka + driver Kafka pick kafka-kafkajs or kafka-rdkafka
@omniqueue/nats + driver NATS / JetStream pick nats-natsjs

🗺️ Coming Soon

CLI tools, gRPC/HTTP code-gen stubs, delay-topic poller containers, and Grafana dashboard plugins

📚 Documentation 🐙 GitHub 📦 NPM

🤝 Contributing

  1. Fork → pnpm i → pnpm -r build
  2. Add tests (pnpm test) – Docker compose spins local RabbitMQ, LocalStack, etc.
  3. Submit PR. All adapters follow the same driver interface; lint passes = merge.