@noddde/rabbitmq

RabbitMQ event bus adapter for noddde. Provides distributed event publishing and subscription with at-least-once delivery guarantees.

Documentation | GitHub

Install

yarn add @noddde/rabbitmq amqplib
# or
npm install @noddde/rabbitmq amqplib

What's Inside

• RabbitMqEventBus — Exchange-based event publishing with topic routing, durable queues, manual acknowledgment, and exponential backoff reconnection
• Prefetch-based backpressure control
• Configurable retry policies per handler

Usage

import { RabbitMqEventBus } from "@noddde/rabbitmq";
import { wireDomain } from "@noddde/engine";

const eventBus = new RabbitMqEventBus({
  url: "amqp://localhost:5672",
  exchangeName: "my-domain-events",
});

await eventBus.connect();

const domain = await wireDomain(definition, {
  eventBus,
});

// Clean shutdown
await eventBus.close();

Configuration

const eventBus = new RabbitMqEventBus({
  url: "amqp://localhost:5672",
  exchangeName: "my-domain-events",
  queuePrefix: "my-service", // Queues are named "${queuePrefix}.${eventName}"
  prefetchCount: 10, // Backpressure control
  resilience: {
    maxAttempts: 5, // Retry the initial connection up to 5 times
    initialDelayMs: 1000, // Base delay in ms (exponential backoff)
    maxDelayMs: 30000,
  },
});

Peer Dependencies

• amqplib >= 0.10.0

Related Packages

| Package | Description | | :--------------------------------------------------------------- | :------------------------------------------ | | @noddde/core | Types, interfaces, and definition functions | | @noddde/engine | Runtime engine with domain orchestration | | @noddde/nats | NATS event bus adapter | | @noddde/kafka | Kafka event bus adapter |

License

MIT