Support for message attributes

mercury2269 · Feb 7, 2020 · e47fbb1 · e47fbb1
1 parent 5c54491
commit e47fbb1
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/main.go b/main.go
@@ -109,6 +109,7 @@ func convertToEntries(messages []*sqs.Message) []*sqs.SendMessageBatchRequestEnt
 		result[i] = &sqs.SendMessageBatchRequestEntry{
 			MessageBody: message.Body,
 			Id:          message.MessageId,
+			MessageAttributes: message.MessageAttributes,
 		}
 	}
 
@@ -133,6 +134,7 @@ func moveMessages(sourceQueueUrl string, destinationQueueUrl string, svc *sqs.SQ
 		VisibilityTimeout:   aws.Int64(2),
 		WaitTimeSeconds:     aws.Int64(0),
 		MaxNumberOfMessages: aws.Int64(10),
+	        MessageAttributeNames: []*string{aws.String(sqs.QueueAttributeNameAll),},
 	}
 
 	log.Info(color.New(color.FgCyan).Sprintf("Starting to move messages..."))