interface RabbitMQConnector
extends QueueConnector

RabbitMQ queue connector for creating adapter instances.

Methods

connect(signal?: AbortSignal): Promise<QueueAdapter>

Establishes connection and returns a queue adapter

end(): Promise<void>

Closes the RabbitMQ connection

Usage

import { type RabbitMQConnector } from ".";