sqs-consumer - npm Package Compare versions

Comparing version 3.7.0 to 3.8.0

index.js

@@ -133,2 +133,3 @@ 'use strict';
       // start polling again once all of the messages have been processed
+      consumer.emit('response_processed');
       consumer._poll();
@@ -135,0 +136,0 @@ });

package.json

 {
   "name": "sqs-consumer",
-  "version": "3.7.0",
+  "version": "3.8.0",
   "description": "Build SQS-based Node applications without the boilerplate",
@@ -5,0 +5,0 @@ "main": "index.js",

README.md

@@ -114,2 +114,3 @@ # sqs-consumer
 |`message_processed`|`message`|Fired when a message is successfully processed and removed from the queue.|
+|`response_processed`|None|Fired after one batch of items (up to `batchSize`) has been successfully processed.|
 |`stopped`|None|Fired when the consumer finally stops its work.|
@@ -116,0 +117,0 @@ |`empty`|None|Fired when the queue is empty (All messages have been consumed).|

test/index.js

@@ -438,2 +438,33 @@ 'use strict';
     });
+
+    it('fires response_processed event for each batch', function (done) {
+      sqs.receiveMessage.yieldsAsync(null, {
+        Messages: [
+          {
+            ReceiptHandle: 'receipt-handle-1',
+            MessageId: '1',
+            Body: 'body-1'
+          },
+          {
+            ReceiptHandle: 'receipt-handle-2',
+            MessageId: '2',
+            Body: 'body-2'
+          }
+        ]
+      });
+      handleMessage.yields(null);
+
+      consumer = new Consumer({
+        queueUrl: 'some-queue-url',
+        messageAttributeNames: ['attribute-1', 'attribute-2'],
+        region: 'some-region',
+        handleMessage: handleMessage,
+        batchSize: 2,
+        sqs: sqs
+      });
+
+      consumer.on('response_processed', done);
+      consumer.start();
+
+    });
   });
@@ -440,0 +471,0 @@

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

28649

increased by3.26%

Lines of code

614

increased by4.78%

Number of lines in readme file

121

increased by0.83%

Worsened metrics

Number of package files

9

decreased by-10%

No dependency changes