amqp-connection-manager - npm Package Compare versions

Comparing version 3.4.2 to 3.4.3

dist/cjs/AmqpConnectionManager.js

@@ -131,3 +131,3 @@ "use strict";
         if (this._closed || this.isConnected()) {
-            return Promise.resolve();
+            return Promise.resolve(null);
         }
@@ -209,2 +209,4 @@ const result = (this._connectPromise = Promise.resolve()
                 this.emit('connect', { connection, url: originalUrl });
+                // Need to return null here, or Bluebird will complain - #171.
+                return null;
             });
@@ -211,0 +213,0 @@ })

dist/esm/AmqpConnectionManager.js

@@ -126,3 +126,3 @@ import amqp from 'amqplib';
         if (this._closed || this.isConnected()) {
-            return Promise.resolve();
+            return Promise.resolve(null);
         }
@@ -204,2 +204,4 @@ const result = (this._connectPromise = Promise.resolve()
                 this.emit('connect', { connection, url: originalUrl });
+                // Need to return null here, or Bluebird will complain - #171.
+                return null;
             });
@@ -206,0 +208,0 @@ })

dist/esm/index.d.ts

 import { AmqpConnectionManagerOptions, IAmqpConnectionManager } from './AmqpConnectionManager.js';
 export type { AmqpConnectionManagerOptions, IAmqpConnectionManager as AmqpConnectionManager, } from './AmqpConnectionManager.js';
 export type { SetupFunc, CreateChannelOpts, default as ChannelWrapper } from './ChannelWrapper.js';
-export declare function connect(urls: string[], options: AmqpConnectionManagerOptions): IAmqpConnectionManager;
+export declare function connect(urls: string[], options?: AmqpConnectionManagerOptions): IAmqpConnectionManager;
 declare const amqp: {
@@ -6,0 +6,0 @@ connect: typeof connect;

package.json

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

No alert changes

Improved metrics

Total package byte prevSize

109006

increased by0.25%

Lines of code

1830

increased by0.22%

No dependency changes