amqpxRabbitMQ for TypeScript

Type-safe messages, automatic reconnect, and a clean composable API built on top of amqplib.

Type-safe messaging

Generic producers and consumers let you define message shapes once and have TypeScript enforce them everywhere.

Pluggable retry strategies handle transient broker failures so your service recovers without manual intervention.

Connection → Channel → Exchange / Queue → Producer / Consumer. Each layer exposes factory methods for the one below.

Per-consumer error handling — drop, requeue, or reject — without tangling application logic with transport concerns.

Built-in batch consumer groups messages for bulk processing with configurable batch sizes, timeouts, and ack coalescing.

In-memory mock implementations for Vitest and Jest ship as dedicated entry points — no broker needed in unit tests.