Upload big sqs messages to s3

sqs/sqs.go

@@ -26,7 +26,7 @@ type Messenger struct {
 	QueueName    string
 	QueueURL     string
 	Region       string
-	S3Session    s3.SessionWithHelpers
+	S3Session    *s3.SessionWithHelpers
 	S3BucketName string
 }
 
@@ -106,7 +106,7 @@ func (m *Messenger) SendSQSMessage(headers map[string]string, body string, curre
 	return *res.MessageId, err
 }
 
-func SendSQSMessage(msgr *Messenger, objectToSend interface{}, currentRequestID *string, sqsType string, headerKey string, messageGroupID ...string) error {
+func SendSQSMessage(msgr Messenger, objectToSend interface{}, currentRequestID *string, sqsType string, headerKey string, messageGroupID ...string) error {
 	msgGrpID := ""
 	if len(messageGroupID) > 0 && messageGroupID[0] != "" {
 		msgGrpID = messageGroupID[0]
@@ -155,7 +155,7 @@ func SendSQSMessage(msgr *Messenger, objectToSend interface{}, currentRequestID
 	return nil
 }
 
-func uploadMessageToS3(session s3.SessionWithHelpers, bucket string, name string, object interface{}) error {
+func uploadMessageToS3(session *s3.SessionWithHelpers, bucket string, name string, object interface{}) error {
 	messageBytes, err := json.Marshal(object)
 	if err != nil {
 		return err
@@ -173,7 +173,7 @@ func uploadMessageToS3(session s3.SessionWithHelpers, bucket string, name string
 	return nil
 }
 
-func RetrieveMessageFromS3(session s3.SessionWithHelpers, bucket string, filename string) ([]byte, error) {
+func RetrieveMessageFromS3(session *s3.SessionWithHelpers, bucket string, filename string) ([]byte, error) {
 	// get the file contents
 	rawObject, err := session.GetObject(bucket, filename, false)
 	if err != nil {