From b553793c638c428e0ffcf88d6ad13ef0488e39e5 Mon Sep 17 00:00:00 2001 From: Michael Date: Sat, 20 Feb 2016 16:53:44 +0100 Subject: [PATCH] Add xml support Changed the line so that xml data is supported --- src/sqs-queue-parallel.coffee | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/sqs-queue-parallel.coffee b/src/sqs-queue-parallel.coffee index 3ebdb1b..8d3402a 100644 --- a/src/sqs-queue-parallel.coffee +++ b/src/sqs-queue-parallel.coffee @@ -45,7 +45,7 @@ module.exports = class SqsQueueParallel extends events.EventEmitter async.eachSeries queue.Messages, (message, next) -> self.emit "message", type: 'message' - data: JSON.parse(message.Body) or message.Body + data: if message.body.indexOf('