sqs_receive.go

sqsClient := sqs.New(awsSession)

result, err := sqsClient.ReceiveMessage(&sqs.ReceiveMessageInput{
	QueueUrl: &queueURL,
	AttributeNames: aws.StringSlice([]string{
		sqs.MessageSystemAttributeNameSentTimestamp,
	}),
	MaxNumberOfMessages: aws.Int64(1),
	MessageAttributeNames: aws.StringSlice([]string{
		sqs.QueueAttributeNameAll,
	}),
	WaitTimeSeconds: aws.Int64(10),
})

if err != nil {
	fmt.Errorf("メッセージを取得できませんでした")
} else if len(result.Messages) > 0 {
	fmt.Println(result.Messages[0])
} else {
	fmt.Println("メッセージはありませんでした")
}