Skip to content
This repository was archived by the owner on Jul 14, 2023. It is now read-only.

Commit 7b8ba01

Browse files
committed
accepting messages in plain text, not json
1 parent 6357cd5 commit 7b8ba01

File tree

2 files changed

+12
-2
lines changed

2 files changed

+12
-2
lines changed

dist/sqs-queue-parallel.js

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -74,9 +74,15 @@
7474
console.log("SqsQueueParallel " + self.config.name + "[" + index + "]: " + queue.Messages.length + " new messages");
7575
}
7676
return async.eachSeries(queue.Messages, function(message, next) {
77+
var messageBody;
78+
try {
79+
messageBody = JSON.parse(message.Body);
80+
} catch (_error) {
81+
messageBody = message.Body;
82+
}
7783
return self.emit("message", {
7884
type: 'message',
79-
data: JSON.parse(message.Body) || message.Body,
85+
data: messageBody,
8086
message: message,
8187
metadata: queue.ResponseMetadata,
8288
url: self.url,

src/sqs-queue-parallel.coffee

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,9 +43,13 @@ module.exports = class SqsQueueParallel extends events.EventEmitter
4343
return next null unless queue.Messages?[0]
4444
console.log "SqsQueueParallel #{ self.config.name }[#{ index }]: #{ queue.Messages.length } new messages" if self.config.debug
4545
async.eachSeries queue.Messages, (message, next) ->
46+
try
47+
messageBody = JSON.parse(message.Body)
48+
catch
49+
messageBody = message.Body
4650
self.emit "message",
4751
type: 'message'
48-
data: JSON.parse(message.Body) or message.Body
52+
data: messageBody
4953
message: message
5054
metadata: queue.ResponseMetadata
5155
url: self.url

0 commit comments

Comments
 (0)