Socket
Socket
Sign inDemoInstall

amqp-connection-manager

Package Overview
Dependencies
Maintainers
1
Versions
67
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

amqp-connection-manager - npm Package Compare versions

Comparing version 4.1.0 to 4.1.1

9

dist/cjs/AmqpConnectionManager.js

@@ -84,2 +84,6 @@ "use strict";

};
let waitTimeout;
if (timeout) {
waitTimeout = (0, helpers_js_1.wait)(timeout);
}
try {

@@ -92,5 +96,5 @@ await Promise.race([

}),
...(timeout
...(waitTimeout
? [
(0, helpers_js_1.wait)(timeout).promise.then(() => {
waitTimeout.promise.then(() => {
throw new Error('amqp-connection-manager: connect timeout');

@@ -103,2 +107,3 @@ }),

finally {
waitTimeout === null || waitTimeout === void 0 ? void 0 : waitTimeout.cancel();
this.removeListener('connectFailed', onConnectFailed);

@@ -105,0 +110,0 @@ }

@@ -79,2 +79,6 @@ import amqp from 'amqplib';

};
let waitTimeout;
if (timeout) {
waitTimeout = wait(timeout);
}
try {

@@ -87,5 +91,5 @@ await Promise.race([

}),
...(timeout
...(waitTimeout
? [
wait(timeout).promise.then(() => {
waitTimeout.promise.then(() => {
throw new Error('amqp-connection-manager: connect timeout');

@@ -98,2 +102,3 @@ }),

finally {
waitTimeout === null || waitTimeout === void 0 ? void 0 : waitTimeout.cancel();
this.removeListener('connectFailed', onConnectFailed);

@@ -100,0 +105,0 @@ }

{
"name": "amqp-connection-manager",
"version": "4.1.0",
"version": "4.1.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

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc