Merge pull request #24 from pagarme/fix-attribute-names-value

Fix attribute names value
pagarme · Nov 25, 2020 · ce365f8 · ce365f8
2 parents df4ff61 + 426ed5f
commit ce365f8
Show file tree

Hide file tree

Showing 5 changed files with 6 additions and 6 deletions.
diff --git a/README.md b/README.md
@@ -76,7 +76,7 @@ Handler function should accept 2 arguments, the first one being the parsed messa
 
 The options object is optional and accept the following properties:
 - `keepMessages` (boolean): To avoid deleting the message after processing it. Default is `false`.
-- `messageAttributesNames` (string array): The value which will be sent to the `receiveMessage` SQS method at the `MessageAttributeNames` property. Default value is `['ALL']`.
+- `messageAttributesNames` (string array): The value which will be sent to the `receiveMessage` SQS method at the `MessageAttributeNames` property. Default value is `['All']`.
 
 After the handler returns (if it returns a Promise, SQS Quooler will wait for it to resolve), the item is automatically deleted from the queue. If your handler throws an error, or returns a rejected Promise, the item will not be removed from the queue.
 

diff --git a/lib/queue.js b/lib/queue.js
@@ -200,7 +200,7 @@ var Queue = function (_EventEmitter) {
         return _bluebird2.default.resolve(self.options.sqs.receiveMessage({
           QueueUrl: self.options.endpoint,
           MaxNumberOfMessages: self.options.concurrency,
-          MessageAttributeNames: options.messageAttributeNames || ['ALL']
+          MessageAttributeNames: options.messageAttributeNames || ['All']
         }).promise()).get('Messages').then(coerce).map(processItem).tap(delay).then(runAgain).catch(handleCriticalError);
       };
 
@@ -223,4 +223,4 @@ var Queue = function (_EventEmitter) {
   return Queue;
 }(_events.EventEmitter);
 
-exports.default = Queue;
+exports.default = Queue;
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "sqs-quooler",
-  "version": "1.7.0",
+  "version": "1.7.1",
   "description": "An abstraction of AWS SQS",
   "license": "MIT",
   "repository": {

diff --git a/src/queue.js b/src/queue.js
@@ -112,7 +112,7 @@ export default class Queue extends EventEmitter {
         .receiveMessage({
           QueueUrl: self.options.endpoint,
           MaxNumberOfMessages: self.options.concurrency,
-          MessageAttributeNames: options.messageAttributeNames || ['ALL'],
+          MessageAttributeNames: options.messageAttributeNames || ['All'],
         })
         .promise())
         .get('Messages')