go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2025-07-04 12:23:39 +08:00
Code Issues Projects Releases Wiki Activity

Update RDB.Dequeue

Browse Source
This commit is contained in:
Ken Hibino 2021-02-24 11:22:05 -08:00
parent 4c2c98db78
commit 02a7c13014
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/rdb/rdb.go
View File

@ -219,6 +219,10 @@ func (r *RDB) dequeue(qnames ...string) (encoded string, deadline int64, err err
if deadline, err = cast.ToInt64E(data[1]); err != nil { if deadline, err = cast.ToInt64E(data[1]); err != nil {
return "", 0, err return "", 0, err
} }
<<<<<<< HEAD
=======
fmt.Printf("debug: Returning msgjson=%s deadline=%d\n", encoded, deadline)
>>>>>>> ebeb409... Update RDB.Dequeue
return encoded, deadline, nil return encoded, deadline, nil
} }
return "", 0, ErrNoProcessableTask return "", 0, ErrNoProcessableTask