Merge pull request #1 from cv65kr/fix-decode-message

Fix message decoding
Admiral-Piett · Dec 16, 2020 · 8cb516e · 8cb516e
2 parents 6ecd9bf + 74f2ca3
commit 8cb516e
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/app/gosns/gosns.go b/app/gosns/gosns.go
@@ -553,7 +553,12 @@ func publishSQS(w http.ResponseWriter, req *http.Request,
 		} else {
 			msg.MessageAttributes = messageAttributes
 			msg.MD5OfMessageAttributes = common.HashAttributes(messageAttributes)
-			msg.MessageBody = []byte(messageBody)
+			m, err := extractMessageFromJSON(messageBody, subs.Protocol)
+			if (err == nil) {
+				msg.MessageBody = []byte(m)
+			} else {
+				msg.MessageBody = []byte(messageBody)
+			}
 		}
 
 		msg.MD5OfMessageBody = common.GetMD5Hash(messageBody)