fix

plum330 · Dec 6, 2021 · ada97ea · ada97ea
1 parent 307b5dc
commit ada97ea
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/xdelay_queue/bucket.go b/xdelay_queue/bucket.go
@@ -18,6 +18,7 @@ func (dq *DelayQueue) addJobToBucketZ(timestamp int64, jobId string) error {
 }
 
 func (dq *DelayQueue) getJobFromBucketZ(key string) (*BucketZ, error) {
+	//zrangebyscore zrangebyscorewithscores
 	result, err := dq.ZRangeWithScores(key, 0, 0).Result()
 	if err != nil {
 		if errors.Is(err, redis.Nil) {

diff --git a/xdelay_queue/delay_queue.go b/xdelay_queue/delay_queue.go
@@ -50,6 +50,7 @@ func (dq *DelayQueue) AddJob(job *Job) error {
 		return errors.New("invalid job")
 	}
 
+	job.Delay = job.Delay + time.Now().Unix()
 	value, err := json.Marshal(job)
 	if err != nil {
 		return errors.WithStack(err)