diff --git a/dist/sqs-queue-parallel.js b/dist/sqs-queue-parallel.js
index 2663227..57fb505 100644
--- a/dist/sqs-queue-parallel.js
+++ b/dist/sqs-queue-parallel.js
@@ -1,5 +1,5 @@
 /**
- * sqs-queue-parallel 0.1.6 <https://github.com/bigluck/sqs-queue-parallel>
+ * sqs-queue-parallel 0.1.7 <https://github.com/bigluck/sqs-queue-parallel>
  * Create a poll of Amazon SQS queue watchers and each one can receive 1+ messages
  *
  * Available under MIT license <https://github.com/bigluck/sqs-queue-parallel/raw/master/LICENSE>
@@ -74,9 +74,15 @@
               console.log("SqsQueueParallel " + self.config.name + "[" + index + "]: " + queue.Messages.length + " new messages");
             }
             return async.eachSeries(queue.Messages, function(message, next) {
+              var data;
+              try {
+                data = JSON.parse(message.Body);
+              } catch (_error) {
+                data = message.Body;
+              }
               return self.emit("message", {
                 type: 'message',
-                data: JSON.parse(message.Body) || message.Body,
+                data: data,
                 message: message,
                 metadata: queue.ResponseMetadata,
                 url: self.url,
diff --git a/package.json b/package.json
index 64afc39..390852d 100644
--- a/package.json
+++ b/package.json
@@ -4,7 +4,7 @@
 	"main": "dist/sqs-queue-parallel",
 	"homepage": "https://github.com/bigluck/sqs-queue-parallel",
 	"author": "Luca Bigon",
-	"version": "0.1.6",
+	"version": "0.1.7",
 	"license": "MIT",
 	"licenses": [
 		{
diff --git a/src/sqs-queue-parallel.coffee b/src/sqs-queue-parallel.coffee
index 3ebdb1b..5dcbbf9 100644
--- a/src/sqs-queue-parallel.coffee
+++ b/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
+							data = JSON.parse(message.Body)
+						catch
+							data = message.Body
 						self.emit "message",
 							type: 'message'
-							data: JSON.parse(message.Body) or message.Body
+							data: data
 							message: message
 							metadata: queue.ResponseMetadata
 							url: self.url