We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 979d8d6 commit faf3703Copy full SHA for faf3703
1 file changed
dtmsvr/api.go
@@ -41,6 +41,7 @@ func svcSubmit(t *TransGlobal) interface{} {
41
}
42
43
// In msg mode, allow delaying consumption by using a custom NextCronTime
44
+ // WaitResult=true and NextCronTime are mutually exclusive, WaitResult takes priority
45
if !t.WaitResult && t.TransType == "msg" && !t.NextCronTime.IsZero() && t.NextCronTime.After(time.Now().Add(3*time.Second)) {
46
return nil
47
0 commit comments