FIFO queues require MessageGroupId in the send message

[ghost]

If the MessageGroupId the send message fails for FIFO queues.

I "hacked" a generated MessageGroupId for each message and set the field, and it worked.

However, I am wondering if it would be possible to set the MessageGroupId based on the src message? I'm not familiar enough with Go or the AWS SQS messages go api to provide a proper solution. Also, I have not tested my change for non-FIFO queues.

[ghost]

The simplistic hack, btw:

diff --git a/main.go b/main.go
index 3c7c42e..991e342 100644
--- a/main.go
+++ b/main.go
@@ -49,6 +49,8 @@ func main() {
                MessageAttributeNames: messageAttributeNames,
        }

+       counter := 0
+
        // loop as long as there are messages on the queue
        for {
                resp, err := client.ReceiveMessage(rmin)
@@ -71,11 +73,14 @@ func main() {
                        go func(m *sqs.Message) {
                                defer wg.Done()

+                               counter += 1
+                               msgGrpId :=  fmt.Sprintf("XXXXXX-%d", counter)
                                // write the message to the destination queue
                                smi := sqs.SendMessageInput{
                                        MessageAttributes: m.MessageAttributes,
                                        MessageBody:       m.Body,
                                        QueueUrl:          dest,
+                                       MessageGroupId:    &msgGrpId,
                                }

                                _, err := client.SendMessage(&smi)