amqp-connection-manager - npm Package Compare versions

Comparing version 3.8.1 to 3.9.0

dist/cjs/ChannelWrapper.js

@@ -631,2 +631,40 @@ "use strict";
     }
+    /** Send a `bindExchange` to the underlying channel. */
+    // eslint-disable-next-line @typescript-eslint/explicit-module-boundary-types
+    async bindExchange(destination, source, pattern, args) {
+        if (this._channel) {
+            return await this._channel.bindExchange(destination, source, pattern, args);
+        }
+        else {
+            throw new Error(`Not connected.`);
+        }
+    }
+    /** Send a `checkExchange` to the underlying channel. */
+    async checkExchange(exchange) {
+        if (this._channel) {
+            return await this._channel.checkExchange(exchange);
+        }
+        else {
+            throw new Error(`Not connected.`);
+        }
+    }
+    /** Send a `deleteExchange` to the underlying channel. */
+    async deleteExchange(exchange, options) {
+        if (this._channel) {
+            return await this._channel.deleteExchange(exchange, options);
+        }
+        else {
+            throw new Error(`Not connected.`);
+        }
+    }
+    /** Send a `unbindExchange` to the underlying channel. */
+    // eslint-disable-next-line @typescript-eslint/explicit-module-boundary-types
+    async unbindExchange(destination, source, pattern, args) {
+        if (this._channel) {
+            return await this._channel.unbindExchange(destination, source, pattern, args);
+        }
+        else {
+            throw new Error(`Not connected.`);
+        }
+    }
     /** Send a `get` to the underlying channel. */
@@ -633,0 +671,0 @@ async get(queue, options) {

dist/esm/ChannelWrapper.d.ts

@@ -236,2 +236,10 @@ /// <reference types="node" />
     assertExchange(exchange: string, type: 'direct' | 'topic' | 'headers' | 'fanout' | 'match' | string, options?: Options.AssertExchange): Promise<amqplib.Replies.AssertExchange>;
+    /** Send a `bindExchange` to the underlying channel. */
+    bindExchange(destination: string, source: string, pattern: string, args?: any): Promise<amqplib.Replies.Empty>;
+    /** Send a `checkExchange` to the underlying channel. */
+    checkExchange(exchange: string): Promise<amqplib.Replies.Empty>;
+    /** Send a `deleteExchange` to the underlying channel. */
+    deleteExchange(exchange: string, options?: Options.DeleteExchange): Promise<amqplib.Replies.Empty>;
+    /** Send a `unbindExchange` to the underlying channel. */
+    unbindExchange(destination: string, source: string, pattern: string, args?: any): Promise<amqplib.Replies.Empty>;
     /** Send a `get` to the underlying channel. */
@@ -238,0 +246,0 @@ get(queue: string, options?: Options.Get): Promise<amqplib.GetMessage | false>;

dist/esm/ChannelWrapper.js

@@ -626,2 +626,40 @@ import { EventEmitter } from 'events';
     }
+    /** Send a `bindExchange` to the underlying channel. */
+    // eslint-disable-next-line @typescript-eslint/explicit-module-boundary-types
+    async bindExchange(destination, source, pattern, args) {
+        if (this._channel) {
+            return await this._channel.bindExchange(destination, source, pattern, args);
+        }
+        else {
+            throw new Error(`Not connected.`);
+        }
+    }
+    /** Send a `checkExchange` to the underlying channel. */
+    async checkExchange(exchange) {
+        if (this._channel) {
+            return await this._channel.checkExchange(exchange);
+        }
+        else {
+            throw new Error(`Not connected.`);
+        }
+    }
+    /** Send a `deleteExchange` to the underlying channel. */
+    async deleteExchange(exchange, options) {
+        if (this._channel) {
+            return await this._channel.deleteExchange(exchange, options);
+        }
+        else {
+            throw new Error(`Not connected.`);
+        }
+    }
+    /** Send a `unbindExchange` to the underlying channel. */
+    // eslint-disable-next-line @typescript-eslint/explicit-module-boundary-types
+    async unbindExchange(destination, source, pattern, args) {
+        if (this._channel) {
+            return await this._channel.unbindExchange(destination, source, pattern, args);
+        }
+        else {
+            throw new Error(`Not connected.`);
+        }
+    }
     /** Send a `get` to the underlying channel. */
@@ -628,0 +666,0 @@ async get(queue, options) {

package.json

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

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

139171

increased by3.3%

Lines of code

2434

increased by3.57%

No dependency changes