diff --git a/main.go b/main.go index ab2a23b..f963bee 100644 --- a/main.go +++ b/main.go @@ -109,8 +109,8 @@ func convertToEntries(messages []*sqs.Message) []*sqs.SendMessageBatchRequestEnt result := make([]*sqs.SendMessageBatchRequestEntry, len(messages)) for i, message := range messages { result[i] = &sqs.SendMessageBatchRequestEntry{ - MessageBody: message.Body, - Id: message.MessageId, + MessageBody: message.Body, + Id: message.MessageId, MessageAttributes: message.MessageAttributes, } } @@ -132,11 +132,11 @@ func convertSuccessfulMessageToBatchRequestEntry(messages []*sqs.Message) []*sqs func moveMessages(sourceQueueUrl string, destinationQueueUrl string, svc *sqs.SQS, numberOfMessages int) { params := &sqs.ReceiveMessageInput{ - QueueUrl: aws.String(sourceQueueUrl), - VisibilityTimeout: aws.Int64(2), - WaitTimeSeconds: aws.Int64(0), - MaxNumberOfMessages: aws.Int64(10), - MessageAttributeNames: []*string{aws.String(sqs.QueueAttributeNameAll),}, + QueueUrl: aws.String(sourceQueueUrl), + 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..."))