I want to process by checking the attribute included in each message.
Please review adding MessageAttributeNames to the worker.go Start method as shown below.
params := &sqs.ReceiveMessageInput{
QueueUrl: aws.String(worker.Config.QueueURL), // Required
MaxNumberOfMessages: aws.Int64(worker.Config.MaxNumberOfMessage),
AttributeNames: []*string{
aws.String("All"), // Required
},
MessageAttributeNames: []*string{
aws.String(sqs.QueueAttributeNameAll),
},
WaitTimeSeconds: aws.Int64(worker.Config.WaitTimeSecond),
}