Merge pull request #61 from kesonan/fix/59

fix #59
zeromicro · Apr 8, 2024 · 28fb062 · 28fb062
2 parents 4a99c09 + a8f1bf1
commit 28fb062
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/dq/consumer.go b/dq/consumer.go
@@ -12,7 +12,6 @@ import (
 
 const (
 	expiration = 3600 // seconds
-	guardValue = "1"
 	tolerance  = time.Minute * 30
 )
 
@@ -51,7 +50,9 @@ func (c *consumerCluster) Consume(consume Consume) {
 			return
 		}
 
-		ok, err := c.red.SetnxEx(key, guardValue, expiration)
+		redisLock := redis.NewRedisLock(c.red, key)
+		redisLock.SetExpire(expiration)
+		ok, err := redisLock.Acquire()
 		if err != nil {
 			logx.Error(err)
 		} else if ok {