redis nil

plum330 · Dec 7, 2021 · 69aef72 · 69aef72
1 parent ada97ea
commit 69aef72
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/xdelay_queue/delay_queue.go b/xdelay_queue/delay_queue.go
@@ -56,10 +56,14 @@ func (dq *DelayQueue) AddJob(job *Job) error {
 		return errors.WithStack(err)
 	}
 
-	return redis.NewScript(`
+	err = redis.NewScript(`
         redis.call("SET", KEYS[1], ARGV[1])
         redis.call("ZADD", KEYS[2], ARGV[2], ARGV[3])
     `).Run(dq.Client, []string{job.Id, <- dq.bucketNameChan}, value, float64(job.Delay), job.Id).Err()
+	if err == nil || errors.Is(err, redis.Nil) {
+		return nil
+	}
+	return errors.WithStack(err)
 }
 
 func (dq *DelayQueue) GetJob(topics []string) (*Job, error) {