diff --git a/pumps/sqs.go b/pumps/sqs.go
index 2858899b7..00d23e229 100644
--- 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 {