@connectum/events-amqp

AMQP and RabbitMQ adapter with topology, confirms, recovery, and external-contract publishing.

Install

npm install @connectum/events-amqp

pnpm add @connectum/events-amqp

bun add @connectum/events-amqp

Start Here

import { AmqpAdapter } from '@connectum/events-amqp';

const adapter = AmqpAdapter({
  url: 'amqp://localhost:5672',
  exchange: 'events',
  exchangeType: 'topic',
});

For a complete, source-verified workflow, continue with the focused guide below.

Key Entry Points

Entry point	Use it to
AmqpAdapter	Connect EventBus to an AMQP broker.
AmqpAdapterOptions	Configure connection, topology, publishing, and recovery.
isAutoRetriablePublishError	Classify adapter failures for retry policy.

Runtime boundaries and extension seams remain in Connectum Runtime Architecture.

Learn / Configure / API Reference

• Learn: Focused guide
• Configure: Task and configuration guidance
• API reference: Exact options and symbols
• Package API index: Generated TypeDoc
• Source: @connectum/events-amqp on GitHub

Related Modules

Compare all Connectum packages by capability.