diff --git a/sqs/sqs.go b/sqs/sqs.go index 77c99286cde157394b7c1b682ac45985a300d5ce..829a7106621c6b25c51e1e81b0dac830c0c8cdde 100644 --- a/sqs/sqs.go +++ b/sqs/sqs.go @@ -3,7 +3,6 @@ package sqs /*Package sqs provides a simple interface to send messages to AWS SQS*/ import ( - "encoding/binary" "encoding/json" "fmt" "github.com/google/uuid" @@ -127,7 +126,7 @@ 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 binary.Size(message) > 0 { + if len(jsonBytes) > 0 { headers[SQSMessageOnS3Key] = "true" id := uuid.New() filename := fmt.Sprintf("%v-%v", sqsType, id.String())