amqp-extension - npm Package Compare versions

Comparing version 4.0.0-beta.2 to 4.0.0-beta.3

CHANGELOG.md

@@ -0,1 +1,8 @@
+# [4.0.0-beta.3](https://github.com/Tada5hi/amqp-extension/compare/v4.0.0-beta.2...v4.0.0-beta.3) (2024-06-12)
+
+
+### Bug Fixes
+
+* only ack message if noAck option is false ([d6102e3](https://github.com/Tada5hi/amqp-extension/commit/d6102e3df431c6710257b5bdf59c8e99672e7df6))
+
 # [4.0.0-beta.2](https://github.com/Tada5hi/amqp-extension/compare/v4.0.0-beta.1...v4.0.0-beta.2) (2024-06-11)
@@ -2,0 +9,0 @@

dist/module.js

@@ -81,3 +81,5 @@ "use strict";
             if (typeof handler === 'undefined') {
-                ch.nack(message, undefined, requeueOnFailure);
+                if (!options.noAck) {
+                    ch.nack(message, undefined, requeueOnFailure);
+                }
                 return;
@@ -87,6 +89,10 @@ }
                 await handler(message, ch);
-                ch.ack(message);
+                if (!options.noAck) {
+                    ch.ack(message);
+                }
             }
             catch (e) {
-                ch.nack(message, undefined, requeueOnFailure);
+                if (!options.noAck) {
+                    ch.nack(message, undefined, requeueOnFailure);
+                }
             }
@@ -93,0 +99,0 @@ };

package.json

 {
     "name": "amqp-extension",
-    "version": "4.0.0-beta.2",
+    "version": "4.0.0-beta.3",
     "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

32570

increased by1.42%

Lines of code

574

increased by1.06%

No dependency changes