sqs-consumer - npm Package Compare versions

Comparing version 2.1.0 to 2.1.1

index.js

@@ -88,3 +88,3 @@ var EventEmitter = require('events').EventEmitter;
 Consumer.prototype._handleSqsResponse = function (err, response) {
-  if (err) this.emit('error', err);
+  if (err) this.emit('error', new Error('SQS receive message failed: ' + err.message));
 
@@ -136,5 +136,9 @@ var consumer = this;
   debug('Deleting message %s', message.MessageId);
-  this.sqs.deleteMessage(deleteParams, cb);
+  this.sqs.deleteMessage(deleteParams, function (err) {
+    if (err) return cb(new Error('SQS delete message failed: ' + err.message));
+
+    cb();
+  });
 };
 
 module.exports = Consumer;

package.json

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

README.md

 # sqs-consumer
 
-[![Build Status](https://travis-ci.org/BBC/sqs-consumer.svg)](https://travis-ci.org/BBC/sqs-consumer) [![Code Climate](https://codeclimate.com/github/BBC/sqs-consumer/badges/gpa.svg)](https://codeclimate.com/github/BBC/sqs-consumer) [![Test Coverage](https://codeclimate.com/github/BBC/sqs-consumer/badges/coverage.svg)](https://codeclimate.com/github/BBC/sqs-consumer)
+[![Build Status](https://travis-ci.org/bbc/sqs-consumer.svg)](https://travis-ci.org/bbc/sqs-consumer) [![Code Climate](https://codeclimate.com/github/BBC/sqs-consumer/badges/gpa.svg)](https://codeclimate.com/github/BBC/sqs-consumer) [![Test Coverage](https://codeclimate.com/github/BBC/sqs-consumer/badges/coverage.svg)](https://codeclimate.com/github/BBC/sqs-consumer)
 
@@ -5,0 +5,0 @@ Build SQS-based applications without the boilerplate. Just define a function that receives an SQS message and call a callback when the message has been processed.

test/index.js

@@ -100,3 +100,4 @@ var Consumer = require('..');
       consumer.on('error', function (err) {
-        assert.equal(err, receiveErr);
+        assert.ok(err);
+        assert.equal(err.message, 'SQS receive message failed: Receive error');
         done();
@@ -115,3 +116,4 @@ });
       consumer.on('error', function (err) {
-        assert.equal(err, deleteErr);
+        assert.ok(err);
+        assert.equal(err.message, 'SQS delete message failed: Delete error');
         done();
@@ -270,2 +272,2 @@ });
   });
-});
+});

No alert changes

Improved metrics

Total package byte prevSize

15833

increased by1.87%

Lines of code

345

increased by1.77%

No dependency changes