go-sqs-poller
go-sqs-poller copied to clipboard
add MessageAttributeNames to sqs.ReceiveMessageInput.
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),
}
Also need this..
I created a PR for this: https://github.com/h2ik/go-sqs-poller/pull/16
Hi there,
my fork supports MessageAttributeNames, check it out https://github.com/aint/go-sqs-poller.