-
Couldn't load subscription status.
- Fork 31
Open
Description
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),
}
melneff
Metadata
Metadata
Assignees
Labels
No labels