amqp-cacoon - npm Package Compare versions

Comparing version 1.1.2 to 1.1.3

build/helpers/message_batching_manager.js

@@ -107,3 +107,7 @@ "use strict";
         // 1. Ack the last message using allUpTo argumetn to specify that all messages up to the last should be nacked
-        channel.ack(messageList[messageList.length - 1], true);
+        //channel.ack(messageList[messageList.length - 1], true);
+        for (var _i = 0, messageList_1 = messageList; _i < messageList_1.length; _i++) {
+            var msg = messageList_1[_i];
+            channel.ack(msg);
+        }
         if (this.logger) {
@@ -127,3 +131,7 @@ this.logger.trace("MessageBatchingManager.ackMessageList: End");
         // 1. Nack the last message using the allUpTo argument to specify that all messages up to the last should be nacked
-        channel.nack(messageList[messageList.length - 1], true, requeue);
+        //channel.nack(messageList[messageList.length - 1], true, requeue);
+        for (var _i = 0, messageList_2 = messageList; _i < messageList_2.length; _i++) {
+            var msg = messageList_2[_i];
+            channel.nack(msg, requeue);
+        }
         if (this.logger) {
@@ -130,0 +138,0 @@ this.logger.trace("MessageBatchingManager.nackMessageList: End");

package.json

 {
   "name": "amqp-cacoon",
-  "version": "1.1.2",
+  "version": "1.1.3",
   "description": "AmqpCacoon is an abstraction around amqplib that provides a simple interface with flow control included out of the box",
@@ -5,0 +5,0 @@ "main": "build/index.js",

No alert changes

Improved metrics

Total package byte prevSize

56294

increased by0.81%

Lines of code

926

increased by0.87%

No dependency changes