Skip to content

Class: AmqpConnectionManager

Defined in: packages/rabbitmq/src/amqp/connectionManager.ts:3

Constructors

Constructor

ts
new AmqpConnectionManager(): AmqpConnectionManager;

Returns

AmqpConnectionManager

Methods

addConnection()

ts
addConnection(connection): void;

Defined in: packages/rabbitmq/src/amqp/connectionManager.ts:6

Parameters

ParameterType
connectionAmqpConnection

Returns

void


clearConnections()

ts
clearConnections(): void;

Defined in: packages/rabbitmq/src/amqp/connectionManager.ts:18

Returns

void


close()

ts
close(): Promise<void>;

Defined in: packages/rabbitmq/src/amqp/connectionManager.ts:22

Returns

Promise<void>


getConnection()

ts
getConnection(name): AmqpConnection | undefined;

Defined in: packages/rabbitmq/src/amqp/connectionManager.ts:10

Parameters

ParameterType
namestring

Returns

AmqpConnection | undefined


getConnections()

ts
getConnections(): AmqpConnection[];

Defined in: packages/rabbitmq/src/amqp/connectionManager.ts:14

Returns

AmqpConnection[]

Released under the MIT License.