interface RabbitMQConnector
extends QueueConnector

Methods

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

Usage

import { type RabbitMQConnector } from ".";