Format code

mercury2269 · Feb 8, 2020 · a068d94 · a068d94
1 parent 17a6c10
commit a068d94
Showing 1 changed file with 7 additions and 7 deletions.
diff --git 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..."))