do not limit qps while qps <= 0

dxh031 · Oct 13, 2015 · 76f10af · 76f10af
1 parent ca640f2
commit 76f10af
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/queue.go b/queue.go
@@ -226,7 +226,9 @@ func (p *MNSQueue) ChangeMessageVisibility(receiptHandle string, visibilityTimeo
 
 func (p *MNSQueue) checkQPS() {
 	p.qpsMonitor.Pulse()
-	for p.qpsMonitor.QPS() > p.qpsLimit {
-		time.Sleep(time.Millisecond * 10)
+	if p.qpsLimit > 0 {
+		for p.qpsMonitor.QPS() > p.qpsLimit {
+			time.Sleep(time.Millisecond * 10)
+		}
 	}
 }