amqp-connection-manager - npm Package Compare versions

Comparing version 4.1.4 to 4.1.5

dist/cjs/AmqpConnectionManager.js

 "use strict";
-var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    var desc = Object.getOwnPropertyDescriptor(m, k);
-    if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
-      desc = { enumerable: true, get: function() { return m[k]; } };
-    }
-    Object.defineProperty(o, k2, desc);
-}) : (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    o[k2] = m[k];
-}));
-var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
-    Object.defineProperty(o, "default", { enumerable: true, value: v });
-}) : function(o, v) {
-    o["default"] = v;
-});
-var __importStar = (this && this.__importStar) || function (mod) {
-    if (mod && mod.__esModule) return mod;
-    var result = {};
-    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
-    __setModuleDefault(result, mod);
-    return result;
-};
 var __importDefault = (this && this.__importDefault) || function (mod) {
@@ -31,3 +8,3 @@ return (mod && mod.__esModule) ? mod : { "default": mod };
 const events_1 = require("events");
-const pb = __importStar(require("promise-breaker"));
+const promise_breaker_1 = __importDefault(require("promise-breaker"));
 const url_1 = require("url");
@@ -218,3 +195,3 @@ const ChannelWrapper_js_1 = __importDefault(require("./ChannelWrapper.js"));
                 this._currentUrl = 0;
-                return pb.call(this._findServers, 0, null);
+                return promise_breaker_1.default.call(this._findServers, 0, null);
             }
@@ -221,0 +198,0 @@ else {

dist/cjs/ChannelWrapper.js

 "use strict";
-var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    var desc = Object.getOwnPropertyDescriptor(m, k);
-    if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
-      desc = { enumerable: true, get: function() { return m[k]; } };
-    }
-    Object.defineProperty(o, k2, desc);
-}) : (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    o[k2] = m[k];
-}));
-var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
-    Object.defineProperty(o, "default", { enumerable: true, value: v });
-}) : function(o, v) {
-    o["default"] = v;
-});
-var __importStar = (this && this.__importStar) || function (mod) {
-    if (mod && mod.__esModule) return mod;
-    var result = {};
-    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
-    __setModuleDefault(result, mod);
-    return result;
-};
 var __importDefault = (this && this.__importDefault) || function (mod) {
@@ -31,3 +8,3 @@ return (mod && mod.__esModule) ? mod : { "default": mod };
 const events_1 = require("events");
-const pb = __importStar(require("promise-breaker"));
+const promise_breaker_1 = __importDefault(require("promise-breaker"));
 const util_1 = require("util");
@@ -164,6 +141,6 @@ const MAX_MESSAGES_PER_BATCH = 1000;
     addSetup(setup, done) {
-        return pb.addCallback(done, (this._settingUp || Promise.resolve()).then(() => {
+        return promise_breaker_1.default.addCallback(done, (this._settingUp || Promise.resolve()).then(() => {
             this._setups.push(setup);
             if (this._channel) {
-                return pb.call(setup, this, this._channel);
+                return promise_breaker_1.default.call(setup, this, this._channel);
             }
@@ -187,5 +164,5 @@ else {
     removeSetup(setup, teardown, done) {
-        return pb.addCallback(done, () => {
+        return promise_breaker_1.default.addCallback(done, () => {
             this._setups = this._setups.filter((s) => s !== setup);
-            return (this._settingUp || Promise.resolve()).then(() => this._channel && teardown ? pb.call(teardown, this, this._channel) : undefined);
+            return (this._settingUp || Promise.resolve()).then(() => this._channel && teardown ? promise_breaker_1.default.call(teardown, this, this._channel) : undefined);
         });
@@ -201,3 +178,3 @@ }
     waitForConnect(done) {
-        return pb.addCallback(done, this._channel && !this._settingUp
+        return promise_breaker_1.default.addCallback(done, this._channel && !this._settingUp
             ? Promise.resolve()
@@ -218,3 +195,3 @@ : new Promise((resolve) => this.once('connect', resolve)));
     publish(exchange, routingKey, content, options, done) {
-        return pb.addCallback(done, new Promise((resolve, reject) => {
+        return promise_breaker_1.default.addCallback(done, new Promise((resolve, reject) => {
             const { timeout, ...opts } = options || {};
@@ -245,3 +222,3 @@ this._enqueueMessage({
         const encodedContent = this._getEncodedMessage(content);
-        return pb.addCallback(done, new Promise((resolve, reject) => {
+        return promise_breaker_1.default.addCallback(done, new Promise((resolve, reject) => {
             const { timeout, ...opts } = options || {};
@@ -296,3 +273,3 @@ this._enqueueMessage({
             // TODO: Use a timeout here to guard against setupFns that never resolve?
-            pb.call(setupFn, this, channel).catch((err) => {
+            promise_breaker_1.default.call(setupFn, this, channel).catch((err) => {
                 if (err.name === 'IllegalOperationError') {
@@ -299,0 +276,0 @@ // Don't emit an error if setups failed because the channel closed.

dist/esm/AmqpConnectionManager.js

 import amqp from 'amqplib';
 import { EventEmitter, once } from 'events';
-import * as pb from 'promise-breaker';
+import pb from 'promise-breaker';
 import { URL } from 'url';
@@ -5,0 +5,0 @@ import ChannelWrapper from './ChannelWrapper.js';

dist/esm/ChannelWrapper.d.ts

@@ -6,3 +6,3 @@ /// <reference types="node" />
 import { EventEmitter } from 'events';
-import * as pb from 'promise-breaker';
+import pb from 'promise-breaker';
 import { IAmqpConnectionManager } from './AmqpConnectionManager.js';
@@ -9,0 +9,0 @@ export declare type Channel = amqplib.ConfirmChannel | amqplib.Channel;

dist/esm/ChannelWrapper.js

 import crypto from 'crypto';
 import { EventEmitter } from 'events';
-import * as pb from 'promise-breaker';
+import pb from 'promise-breaker';
 import { promisify } from 'util';
@@ -5,0 +5,0 @@ const MAX_MESSAGES_PER_BATCH = 1000;

package.json

 {
     "name": "amqp-connection-manager",
-    "version": "4.1.4",
+    "version": "4.1.5",
     "description": "Auto-reconnect and round robin support for amqplib.",
@@ -5,0 +5,0 @@ "module": "./dist/esm/index.js",

No alert changes

Worsened metrics

Total package byte prevSize

142121

decreased by-1.28%

Lines of code

2489

decreased by-1.81%

No dependency changes