fix

plum330 · Dec 7, 2021 · 466cb66 · 466cb66
1 parent 84eabe1
commit 466cb66
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/xdelay_queue/delay_queue.go b/xdelay_queue/delay_queue.go
@@ -133,11 +133,11 @@ func (dq *DelayQueue) handleTicker(t time.Time, bucketName string) {
 	for {
 		bucketZ, err := dq.getJobFromBucketZ(bucketName)
 		if err != nil {
-			continue
+			return
 		}
 
 		if bucketZ == nil {
-			continue
+			return
 		}
 
 		job, err := dq.getJob(bucketZ.jobId)