Appearance

Connectum API Reference / AmqpAdapter

Function: AmqpAdapter() ​

AmqpAdapter(options): EventAdapter

Defined in: AmqpAdapter.ts:77

Create an AMQP/RabbitMQ adapter for @connectum/events.

Parameters ​

options ​

AmqpAdapterOptions

AMQP adapter configuration

Returns ​

EventAdapter

EventAdapter instance

Example ​

typescript
import { AmqpAdapter } from "@connectum/events-amqp";
import { createEventBus } from "@connectum/events";

const bus = createEventBus({
    adapter: AmqpAdapter({ url: "amqp://guest:guest@localhost:5672" }),
    routes: [myRoutes],
});
await bus.start();