basalt / queue-rabbitmq/src / AmqpConnection

Interface: AmqpConnection

Defined in: queue-rabbitmq/src/index.ts:40

Methods

close()

> close(): Promise<void>

Defined in: queue-rabbitmq/src/index.ts:46

Returns

Promise<void>

---

createChannel()

> createChannel(): Promise<AmqpChannel>

Defined in: queue-rabbitmq/src/index.ts:43

Returns

Promise<AmqpChannel>

---

createConfirmChannel()?

> optional createConfirmChannel(): Promise<AmqpChannel>

Defined in: queue-rabbitmq/src/index.ts:45

Preferred when present: publisher-confirm channel (amqplib supports it).

Returns

Promise<AmqpChannel>

---

on()?

> optional on(event, listener): void

Defined in: queue-rabbitmq/src/index.ts:42

amqplib connections are EventEmitters; optional so test fakes stay tiny.

Parameters

event

"error" | "close"

listener

(error?) => void

Returns

void