amqp-connection-manager
Advanced tools
Comparing version 3.5.0 to 3.5.1
@@ -156,13 +156,9 @@ /// <reference types="node" /> | ||
private _onChannelClose; | ||
_onDisconnect(ex: { | ||
err: Error & { | ||
code: number; | ||
}; | ||
}): void; | ||
private _onDisconnect; | ||
queueLength(): number; | ||
close(): Promise<void>; | ||
_shouldPublish(): boolean; | ||
_startWorker(): void; | ||
_canWaitReconnection(): boolean; | ||
_publishQueuedMessages(workerNumber: number): void; | ||
private _shouldPublish; | ||
private _startWorker; | ||
private _canWaitReconnection; | ||
private _publishQueuedMessages; | ||
/** Send an `ack` to the underlying channel. */ | ||
@@ -169,0 +165,0 @@ ack(message: amqplib.Message, allUpTo?: boolean): void; |
{ | ||
"name": "amqp-connection-manager", | ||
"version": "3.5.0", | ||
"version": "3.5.1", | ||
"description": "Auto-reconnect and round robin support for amqplib.", | ||
@@ -5,0 +5,0 @@ "module": "./dist/esm/index.js", |
Sorry, the diff of this file is not supported yet
111935
1879