amqp-extension - npm Package Compare versions

Comparing version 3.1.1 to 3.2.0

CHANGELOG.md

@@ -0,1 +1,13 @@
+# [3.2.0](https://github.com/Tada5hi/amqp-extension/compare/v3.1.1...v3.2.0) (2024-03-11)
+
+
+### Bug Fixes
+
+* remove unnecessary alias option ([8027d0a](https://github.com/Tada5hi/amqp-extension/commit/8027d0afb2063e5d0387dacf26cd77444dc933e4))
+
+
+### Features
+
+* allways close channel after publishing ([a9b300f](https://github.com/Tada5hi/amqp-extension/commit/a9b300f6ab64d176a656cf9fc485f31a36168a7f))
+
 ## [3.1.1](https://github.com/Tada5hi/amqp-extension/compare/v3.1.0...v3.1.1) (2024-03-07)
@@ -2,0 +14,0 @@

dist/consume/utils.js

@@ -7,3 +7,2 @@ "use strict";
     return (0, utils_1.removeKeysFromOptions)({ ...options }, [
-        'alias',
         'exchange',
@@ -10,0 +9,0 @@ 'queueName',

dist/module.js

@@ -160,6 +160,8 @@ "use strict";
             }
-            return channel.publish(this.config.exchange.name, exchangeOptions.routingKey, buffer, (0, publish_1.buildDriverPublishOptions)({
+            const published = channel.publish(this.config.exchange.name, exchangeOptions.routingKey, buffer, (0, publish_1.buildDriverPublishOptions)({
                 persistent: true,
                 ...options,
             }));
+            await channel.close();
+            return published;
         }
@@ -175,8 +177,10 @@ // publish to default exchange
         });
-        return channel.sendToQueue(queueName, buffer, (0, publish_1.buildDriverPublishOptions)({
+        const published = channel.sendToQueue(queueName, buffer, (0, publish_1.buildDriverPublishOptions)({
             persistent: true,
             ...options,
         }));
+        await channel.close();
+        return published;
     }
 }
 exports.Client = Client;

dist/publish/utils.js

@@ -7,3 +7,2 @@ "use strict";
     return (0, utils_1.removeKeysFromOptions)({ ...options }, [
-        'alias',
         'exchange',
@@ -10,0 +9,0 @@ 'queueName',

dist/type.d.ts

 import type { Options } from 'amqplib';
-import type { ConfigInput } from './config';
 import type { ExchangeOptions } from './exchange';
 type CommonOptions = {
     /**
-     * Config key or object.
-     */
-    alias?: string | ConfigInput;
-    /**
      * Exchange
@@ -11,0 +6,0 @@ *

package.json

 {
     "name": "amqp-extension",
-    "version": "3.1.1",
+    "version": "3.2.0",
     "description": "An amqp extension with functions and utility functions to consume and publish queue messages.",
@@ -5,0 +5,0 @@ "main": "./dist/index.js",

No alert changes

Improved metrics

Total package byte prevSize

34974

increased by1.13%

Worsened metrics

Lines of code

599

decreased by-0.5%

No dependency changes