Limit SQS messages to 200 KB

sqs/sqs.go

@@ -126,10 +126,12 @@ func SendSQSMessage(msgr Messenger, objectToSend interface{}, currentRequestID *
 
 	// If bigger than 200 KB upload message to s3 and send s3 file name to sqs
 	// The sqs receiver should check the header to see if the message is in the body or on s3
-	if len(jsonBytes) > 0 {
+	if len(jsonBytes) > 200000 {
+
 		headers[SQSMessageOnS3Key] = "true"
 		id := uuid.New()
 		filename := fmt.Sprintf("%v-%v", sqsType, id.String())
+		logs.Info("SQS message too big, saving to S3 with filename = %s", filename)
 
 		err := uploadMessageToS3(msgr.S3Session, msgr.S3BucketName, filename, jsonBytes)
 		if err != nil {