add conditions for delay seconds

TykTechnologies · Nov 20, 2023 · ad26edf · ad26edf
1 parent a75b4c8
commit ad26edf
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pumps/sqs.go b/pumps/sqs.go
@@ -109,6 +109,9 @@ func (s *SQSPump) WriteData(ctx context.Context, data []interface{}) error {
 		if s.SQSConf.AWSMessageGroupID != "" {
 			messages[i].MessageGroupId = aws.String(s.SQSConf.AWSMessageGroupID)
 		}
+		if s.SQSConf.AWSDelaySeconds != 0 {
+			messages[i].DelaySeconds = s.SQSConf.AWSDelaySeconds
+		}
 	}
 	SQSError := s.write(ctx, messages)
 	if SQSError != nil {