Skip to content
Snippets Groups Projects
Commit 761e6711 authored by Johan de Klerk's avatar Johan de Klerk
Browse files

Revert "Upload big sqs messages to s3"

This reverts commit 88de2e49.
parent 88de2e49
No related branches found
No related tags found
No related merge requests found
...@@ -26,7 +26,7 @@ type Messenger struct { ...@@ -26,7 +26,7 @@ type Messenger struct {
QueueName string QueueName string
QueueURL string QueueURL string
Region string Region string
S3Session *s3.SessionWithHelpers S3Session s3.SessionWithHelpers
S3BucketName string S3BucketName string
} }
...@@ -106,7 +106,7 @@ func (m *Messenger) SendSQSMessage(headers map[string]string, body string, curre ...@@ -106,7 +106,7 @@ func (m *Messenger) SendSQSMessage(headers map[string]string, body string, curre
return *res.MessageId, err 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 := "" msgGrpID := ""
if len(messageGroupID) > 0 && messageGroupID[0] != "" { if len(messageGroupID) > 0 && messageGroupID[0] != "" {
msgGrpID = messageGroupID[0] msgGrpID = messageGroupID[0]
...@@ -155,7 +155,7 @@ func SendSQSMessage(msgr Messenger, objectToSend interface{}, currentRequestID * ...@@ -155,7 +155,7 @@ func SendSQSMessage(msgr Messenger, objectToSend interface{}, currentRequestID *
return nil 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) messageBytes, err := json.Marshal(object)
if err != nil { if err != nil {
return err return err
...@@ -173,7 +173,7 @@ func uploadMessageToS3(session *s3.SessionWithHelpers, bucket string, name strin ...@@ -173,7 +173,7 @@ func uploadMessageToS3(session *s3.SessionWithHelpers, bucket string, name strin
return nil 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 // get the file contents
rawObject, err := session.GetObject(bucket, filename, false) rawObject, err := session.GetObject(bucket, filename, false)
if err != nil { if err != nil {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment