[ISSUE apache#640]fix PullInterval unit. (apache#639)

twz915 · web-flow · commit cccc454669aa · 2021-04-14T21:00:23.000+08:00
* fix PullInterval unit
diff --git a/consumer/push_consumer.go b/consumer/push_consumer.go
@@ -492,7 +492,7 @@ func (pc *pushConsumer) validate() {
 		}
 	}
 
-	if pc.option.PullInterval < 0 || pc.option.PullInterval > 65535 {
+	if pc.option.PullInterval < 0 || pc.option.PullInterval > 65535*time.Millisecond {
 		rlog.Error("option.PullInterval out of range [0, 65535]", nil)
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -492,7 +492,7 @@ func (pc *pushConsumer) validate() {`
`492`	`492`	`}`
`493`	`493`	`}`
`494`	`494`
`495`		`- if pc.option.PullInterval < 0 \|\| pc.option.PullInterval > 65535 {`
	`495`	`+ if pc.option.PullInterval < 0 \|\| pc.option.PullInterval > 65535*time.Millisecond {`
`496`	`496`	`rlog.Error("option.PullInterval out of range [0, 65535]", nil)`
`497`	`497`	`}`
`498`	`498`