amqp-connection-manager
Advanced tools
Comparing version 4.1.8 to 4.1.9
@@ -104,4 +104,4 @@ "use strict"; | ||
const onConnectFailed = ({ err }) => { | ||
// Ignore disconnects caused by dead servers etc., but throw on operational errors like bad credentials. | ||
if (err.isOperational) { | ||
// Ignore disconnects caused bad credentials. | ||
if (err.message.includes('ACCESS-REFUSED') || err.message.includes('403')) { | ||
reject(err); | ||
@@ -108,0 +108,0 @@ } |
@@ -12,3 +12,3 @@ /// <reference types="node" /> | ||
url: string; | ||
connectionOptions?: AmpqConnectionOptions; | ||
connectionOptions?: AmqpConnectionOptions; | ||
}; | ||
@@ -27,3 +27,3 @@ export interface ConnectListener { | ||
} | ||
export declare type AmpqConnectionOptions = (ConnectionOptions | TcpSocketConnectOpts) & { | ||
export declare type AmqpConnectionOptions = (ConnectionOptions | TcpSocketConnectOpts) & { | ||
noDelay?: boolean; | ||
@@ -61,6 +61,6 @@ timeout?: number; | ||
/** Connection options, passed as options to the amqplib.connect() method. */ | ||
connectionOptions?: AmpqConnectionOptions; | ||
connectionOptions?: AmqpConnectionOptions; | ||
} | ||
export interface IAmqpConnectionManager { | ||
connectionOptions?: AmpqConnectionOptions; | ||
connectionOptions?: AmqpConnectionOptions; | ||
heartbeatIntervalInSeconds: number; | ||
@@ -141,3 +141,3 @@ reconnectTimeInSeconds: number; | ||
private _urls?; | ||
connectionOptions: AmpqConnectionOptions | undefined; | ||
connectionOptions: AmqpConnectionOptions | undefined; | ||
heartbeatIntervalInSeconds: number; | ||
@@ -144,0 +144,0 @@ reconnectTimeInSeconds: number; |
@@ -76,4 +76,4 @@ import * as amqp from 'amqplib'; | ||
const onConnectFailed = ({ err }) => { | ||
// Ignore disconnects caused by dead servers etc., but throw on operational errors like bad credentials. | ||
if (err.isOperational) { | ||
// Ignore disconnects caused bad credentials. | ||
if (err.message.includes('ACCESS-REFUSED') || err.message.includes('403')) { | ||
reject(err); | ||
@@ -80,0 +80,0 @@ } |
{ | ||
"name": "amqp-connection-manager", | ||
"version": "4.1.8", | ||
"version": "4.1.9", | ||
"description": "Auto-reconnect and round robin support for amqplib.", | ||
@@ -32,8 +32,8 @@ "module": "./dist/esm/index.js", | ||
"@types/chai-string": "^1.4.2", | ||
"@types/jest": "^27.0.1", | ||
"@types/jest": "^29.2.0", | ||
"@types/node": "^18.7.23", | ||
"@types/whatwg-url": "^8.2.1", | ||
"@types/whatwg-url": "^11.0.0", | ||
"@typescript-eslint/eslint-plugin": "^5.9.0", | ||
"@typescript-eslint/parser": "^5.9.0", | ||
"amqplib": "^0.8.0", | ||
"amqplib": "^0.10.3", | ||
"chai": "^4.1.2", | ||
@@ -49,7 +49,7 @@ "chai-as-promised": "^7.1.1", | ||
"greenkeeper-lockfile": "^1.14.0", | ||
"husky": "^7.0.1", | ||
"husky": "^8.0.1", | ||
"istanbul": "^0.4.0", | ||
"jest": "^27.0.6", | ||
"jest": "^29.2.1", | ||
"jest-ts-webcompat-resolver": "^1.0.0", | ||
"lint-staged": "^12.1.7", | ||
"lint-staged": "^13.0.3", | ||
"prettier": "^2.3.2", | ||
@@ -59,3 +59,3 @@ "pretty-quick": "^3.1.1", | ||
"semantic-release": "^19.0.2", | ||
"ts-jest": "^27.0.5", | ||
"ts-jest": "^29.0.3", | ||
"ts-node": "^10.2.1", | ||
@@ -62,0 +62,0 @@ "typescript": "^4.3.5" |
Sorry, the diff of this file is not supported yet
144372