accepting messages in plain text, not json

Author: caiokf

src/sqs-queue-parallel.coffee

@@ -43,9 +43,13 @@ module.exports = class SqsQueueParallel extends events.EventEmitter
 					return next null unless queue.Messages?[0]
 					console.log "SqsQueueParallel #{ self.config.name }[#{ index }]: #{ queue.Messages.length } new messages" if self.config.debug
 					async.eachSeries queue.Messages, (message, next) ->
+						try
+							messageBody = JSON.parse(message.Body)
+						catch
+							messageBody = message.Body
 						self.emit "message",
 							type: 'message'
-							data: JSON.parse(message.Body) or message.Body
+							data: messageBody
 							message: message
 							metadata: queue.ResponseMetadata
 							url: self.url