amqp-cacoon - npm Package Compare versions

Comparing version 1.1.0 to 1.1.1

build/helpers/message_batching_manager.d.ts

@@ -12,3 +12,3 @@ import { Channel, ConsumeMessage, ConsumeBatchMessages } from '../index';
 export default class MessageBatchingManager {
-    config: IMessageBatchingManagerConfig;
+    private config;
     private unackedMessageList;
@@ -18,2 +18,3 @@ private bufferSize;
     private amqpChannel?;
+    private logger?;
     constructor(config: IMessageBatchingManagerConfig);
@@ -20,0 +21,0 @@ /**

build/helpers/message_batching_manager.js

@@ -44,2 +44,3 @@ "use strict";
         this.bufferSize = 1;
+        this.logger = config.providers.logger;
         this.resetMessages();
@@ -103,2 +104,5 @@ }
     MessageBatchingManager.prototype.ackMessageList = function (channel, messageList, allUpTo) {
+        if (this.logger) {
+            this.logger.trace("MessageBatchingManager.ackMessageList: Start");
+        }
         // 1. Loop over all messages in list and ack them
@@ -109,2 +113,5 @@ for (var _i = 0, messageList_1 = messageList; _i < messageList_1.length; _i++) {
         }
+        if (this.logger) {
+            this.logger.trace("MessageBatchingManager.ackMessageList: End");
+        }
     };
@@ -121,2 +128,5 @@ /**
     MessageBatchingManager.prototype.nackMessageList = function (channel, messageList, allUpTo, requeue) {
+        if (this.logger) {
+            this.logger.trace("MessageBatchingManager.nackMessageList: Start");
+        }
         // 1. Loop over all messages in list and nack them
@@ -127,2 +137,5 @@ for (var _i = 0, messageList_2 = messageList; _i < messageList_2.length; _i++) {
         }
+        if (this.logger) {
+            this.logger.trace("MessageBatchingManager.nackMessageList: End");
+        }
     };
@@ -162,6 +175,6 @@ /**
                             ackAll: function (allUpTo) {
-                                return _this.ackMessageList.bind(_this, channel, unackedMessageList, allUpTo);
+                                return _this.ackMessageList(channel, unackedMessageList, allUpTo);
                             },
                             nackAll: function (allUpTo, requeue) {
-                                return _this.nackMessageList.bind(_this, channel, unackedMessageList, allUpTo, requeue);
+                                return _this.nackMessageList(channel, unackedMessageList, allUpTo, requeue);
                             },
@@ -168,0 +181,0 @@ };

build/index.d.ts

@@ -12,4 +12,4 @@ import amqp from 'amqplib';
     messages: Array<ConsumeMessage>;
-    ackAll: (allUpTo?: boolean) => {};
-    nackAll: (allUpTo?: boolean, requeue?: boolean) => {};
+    ackAll: (allUpTo?: boolean) => void;
+    nackAll: (allUpTo?: boolean, requeue?: boolean) => void;
 }
@@ -16,0 +16,0 @@ export interface ConsumerOptions extends Options.Consume {

package.json

 {
   "name": "amqp-cacoon",
-  "version": "1.1.0",
+  "version": "1.1.1",
   "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

56006

increased by1.55%

Lines of code

926

increased by1.54%

No dependency changes