RabbitMQ queue connector for creating adapter instances.
connect(signal?: AbortSignal): Promise<QueueAdapter>
Establishes connection and returns a queue adapter
end(): Promise<void>
Closes the RabbitMQ connection
RabbitMQ queue connector for creating adapter instances.
connect(signal?: AbortSignal): Promise<QueueAdapter>
Establishes connection and returns a queue adapter
end(): Promise<void>
Closes the RabbitMQ connection
import { type RabbitMQConnector } from ".";