From 761e6711b5a491cb9a3b48d84a1f3febc9a181f1 Mon Sep 17 00:00:00 2001
From: Johan de Klerk <jdeklerk00@gmail.com>
Date: Wed, 9 Feb 2022 09:31:19 +0200
Subject: [PATCH] Revert "Upload big sqs messages to s3"
This reverts commit 88de2e490d96095795b98a3be1e00a547eee6542.
---
sqs/sqs.go | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/sqs/sqs.go b/sqs/sqs.go
index 745d888..0330fff 100644
--- a/sqs/sqs.go
+++ b/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 strin
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 {
--
GitLab