Connectum API Reference / AmqpAdapterOptions

Interface: AmqpAdapterOptions

Defined in: types.ts:10

Options for creating an AMQP/RabbitMQ adapter.

Properties

consumerOptions?

readonly optional consumerOptions: AmqpConsumerOptions

Defined in: types.ts:50

Consumer options.

---

exchange?

readonly optional exchange: string

Defined in: types.ts:28

Exchange name for publishing and subscribing.

Default

"connectum.events"

---

exchangeOptions?

readonly optional exchangeOptions: AmqpExchangeOptions

Defined in: types.ts:40

Exchange assertion options.

---

exchangeType?

readonly optional exchangeType: "topic" | "direct" | "fanout" | "headers"

Defined in: types.ts:35

Exchange type.

Default

"topic"

---

publisherOptions?

readonly optional publisherOptions: AmqpPublisherOptions

Defined in: types.ts:55

Publisher options.

---

queueOptions?

readonly optional queueOptions: AmqpQueueOptions

Defined in: types.ts:45

Default queue assertion options.

---

socketOptions?

readonly optional socketOptions: Record<string, unknown>

Defined in: types.ts:21

Socket options passed to amqplib.connect().

---

url

readonly url: string

Defined in: types.ts:16

AMQP connection URL.

Example

"amqp://guest:guest@localhost:5672"