package/delayqueue
1
0
Fork 0
mirror of https://github.com/HDT3213/delayqueue.git synced 2025-10-05 07:06:53 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

support go-redis/v9

Browse Source
This commit is contained in:
finley
2023-06-27 06:52:00 +08:00
parent 455a9ab414
commit 4cae62d624
7 changed files with 18 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
delayqueue.go
View File

@@ -3,8 +3,8 @@ package delayqueue
import (
"context"
"fmt"
"github.com/go-redis/redis/v8"
"github.com/google/uuid"
"github.com/redis/go-redis/v9"
"log"
"sync"
"time"
@@ -179,7 +179,7 @@ func (q *DelayQueue) SendScheduleMsg(payload string, t time.Time, opts ...interf
return fmt.Errorf("store retry count failed: %v", err)
}
// put to pending
err = q.redisCli.ZAdd(ctx, q.pendingKey, &redis.Z{Score: float64(t.Unix()), Member: idStr}).Err()
err = q.redisCli.ZAdd(ctx, q.pendingKey, redis.Z{Score: float64(t.Unix()), Member: idStr}).Err()
if err != nil {
return fmt.Errorf("push to pending failed: %v", err)
}
@@ -340,7 +340,7 @@ func (q *DelayQueue) ack(idStr string) error {
func (q *DelayQueue) nack(idStr string) error {
ctx := context.Background()
// update retry time as now, unack2Retry will move it to retry immediately
err := q.redisCli.ZAdd(ctx, q.unAckKey, &redis.Z{
err := q.redisCli.ZAdd(ctx, q.unAckKey, redis.Z{
Member: idStr,
Score: float64(time.Now().Unix()),
}).Err()