fix readme typo

PayU · Jan 13, 2020 · 4f8316a · 4f8316a
1 parent 6ef408b
commit 4f8316a
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/out_sqs.go b/out_sqs.go
@@ -160,9 +160,8 @@ func FLBPluginFlushCtx(ctx, data unsafe.Pointer, length C.int, tag *C.char) int
 		MessageCounter++
 
 		sqsRecord = &sqs.SendMessageBatchRequestEntry{
-			Id:             aws.String(fmt.Sprintf("MessageNumber-%d", MessageCounter)),
-			MessageBody:    aws.String(recordString),
-			MessageGroupId: aws.String(sqsConf.queueMessageGroupID),
+			Id:          aws.String(fmt.Sprintf("MessageNumber-%d", MessageCounter)),
+			MessageBody: aws.String(recordString),
 		}
 
 		if sqsConf.pluginTagAttribute != "" {
@@ -174,6 +173,10 @@ func FLBPluginFlushCtx(ctx, data unsafe.Pointer, length C.int, tag *C.char) int
 			}
 		}
 
+		if sqsConf.queueMessageGroupID != "" {
+			sqsRecord.MessageGroupId = aws.String(sqsConf.queueMessageGroupID)
+		}
+
 		SqsRecords = append(SqsRecords, sqsRecord)
 
 		if MessageCounter == 10 {