queue-processor - npm Package Compare versions

Comparing version 1.0.3 to 1.1.0

index.js

 var AWS = require('aws-sdk');
 
-function deleteMessage(sqs, queue, messageHandle, logger) {
+function deleteMessage(sqs, queue, messageHandle, logger, recurse) {
     sqs.deleteMessage({
@@ -9,4 +9,6 @@ QueueUrl: queue,
         if (error) {
-            logger.error(error);
+            logger.error('Error deleting message from SQS: ' + error);
         }
+
+        recurse();
     });
@@ -17,9 +19,11 @@ }
     return function(error) {
-        recurse();
+        if (error) {
+            logger.error('Message processing error: ' + error);
 
-        if (error && !config.deleteOnError) {
-            return;
+            if (!config.deleteOnError) {
+                return recurse();
+            }
         }
 
-        deleteMessage(sqs, config.queueUrl, message.ReceiptHandle, logger);
+        deleteMessage(sqs, config.queueUrl, message.ReceiptHandle, logger, recurse);
     };
@@ -39,3 +43,3 @@ }
             if (error) {
-                logger.error(error);
+                logger.error('Error recieving message from SQS: ' + error);
             }
@@ -42,0 +46,0 @@

package.json

 {
   "name": "queue-processor",
-  "version": "1.0.3",
+  "version": "1.1.0",
   "description": "Processes an AWS SQS queue",
@@ -5,0 +5,0 @@ "main": "index.js",

No alert changes

Improved metrics

Total package byte prevSize

5423

increased by3.91%

Lines of code

63

increased by5%

No dependency changes