SQS receive and delete

main.go

package main

import (
	"fmt"
	"log"

	"github.com/aws/aws-sdk-go/aws"
	"github.com/aws/aws-sdk-go/aws/session"
	"github.com/aws/aws-sdk-go/service/sqs"
)

func main() {

	var queueURL string = "QUEUE URL HERE"
	var maxMessages int64 = 5
	var longPollDur int64 = 10

	sess := session.Must(
		session.NewSession(&aws.Config{Region: aws.String("REGION THE QUEUE IS IN HERE")}),
	)

	client := sqs.New(sess)

	recIn := sqs.ReceiveMessageInput{
		QueueUrl:            &queueURL,
		MaxNumberOfMessages: &maxMessages,
		WaitTimeSeconds:     &longPollDur,
	}

	resp, err := client.ReceiveMessage(&recIn)

	if err != nil {
		log.Fatal(err)
	}

	for key, msg := range resp.Messages {
		fmt.Printf("The body of message #%d is [%s]\n", key, *msg.Body)

		_, err := client.DeleteMessage(
			&sqs.DeleteMessageInput{
				QueueUrl:      &queueURL,
				ReceiptHandle: msg.ReceiptHandle,
			},
		)

		if err != nil {
			log.Fatal(err)
		}
	}
}