sqs-consumer - npm Package Compare versions

Comparing version 2.1.1 to 2.1.2

index.js

		@@ -0,4 +1,5 @@
		'use strict';

		var EventEmitter = require('events').EventEmitter;
		var util = require('util');
		var _ = require('lodash');
		var async = require('async');
		@@ -9,3 +10,2 @@ var AWS = require('aws-sdk');
		'queueUrl',
		'region',
		'handleMessage'
		@@ -43,3 +43,3 @@ ];
		this.sqs = options.sqs \|\| new AWS.SQS({
		region: options.region
		region: options.region \|\| 'eu-west-1'
		});
		@@ -46,0 +46,0 @@ }

package.json

		{
		"name": "sqs-consumer",
		"version": "2.1.1",
		"version": "2.1.2",
		"description": "Build SQS-based Node applications without the boilerplate",
		@@ -35,5 +35,4 @@ "main": "index.js",
		"codeclimate-test-reporter": "0.0.4",
		"debug": "^2.1.0",
		"lodash": "^2.4.1"
		"debug": "^2.1.0"
		}
		}

README.md

		@@ -21,3 +21,2 @@ # sqs-consumer
		queueUrl: 'https://sqs.eu-west-1.amazonaws.com/account-id/queue-name',
		region: 'eu-west-1',
		handleMessage: function (message, done) {
		@@ -50,3 +49,3 @@ // do some work with `message`
		* `queueUrl` - _String_ - The SQS queue URL
		* `region` - _String_ - The AWS region
		* `region` - _String_ - The AWS region (default `eu-west-1`)
		* `handleMessage` - _Function_ - A function to be called whenever a message is receieved. Receives an SQS message object as its first argument and a function to call when the message has been handled as its second argument (i.e. `handleMessage(message, done)`).
		@@ -53,0 +52,0 @@ * `batchSize` - _Number_ - The number of messages to request from SQS when polling (default `1`). This cannot be higher than the AWS limit of 10.

test/index.js

		@@ -0,1 +1,3 @@
		'use strict';

		var Consumer = require('..');
		@@ -40,11 +42,2 @@ var assert = require('assert');

		it('requires an AWS region to be set', function () {
		assert.throws(function () {
		new Consumer({
		queueUrl: 'some-queue-url',
		handleMessage: handleMessage
		});
		});
		});

		it('requires a handleMessage function to be set', function () {
		@@ -51,0 +44,0 @@ assert.throws(function () {

New alerts