Rabbit RelayType-safe messaging for RabbitMQ in Node.js

Fast. Typed. Resilient.

Get Started

Why Rabbit Relay?

GitHub

🧠

Simple, Typed API

Publish and consume strongly typed events with full TypeScript safety.

🛡️

Publisher Confirms

Wait for broker acknowledgements to guarantee message delivery.

🔁

Built-in RPC

Request–reply messaging with correlation IDs and timeouts handled.

🚦

Backpressure Control

Automatically pauses publishing when channels are saturated.

🚨

Failure Routing

Route failures to retries or dead-letter queues with zero boilerplate.

🔄

Auto Reconnect

Restores connections, channels, queues, and bindings automatically.

🧬

Duplicate Guard

Prevents reprocessing with TTL-based message de-duplication.

🧩

Plugin Hooks

Extend behavior with lightweight hooks for logging and metrics.

Example

import { RabbitMQBroker, event } from "@bitspacerlabs/rabbit-relay";

const broker = new RabbitMQBroker("payments-service");

const charge = event("payments.charge", "v1").of<{
  orderId: string;
  amount: number;
}>();

const pub = await broker
  .queue("payments_queue")
  .exchange("payments", { exchangeType: "topic" });

await pub.produce(
  charge({ orderId: "ORD-1", amount: 99.5 })
);