diff --git a/internal/rdb/rdb.go b/internal/rdb/rdb.go index 58025c9..7c8f4f8 100644 --- a/internal/rdb/rdb.go +++ b/internal/rdb/rdb.go @@ -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 { return "", 0, err } +<<<<<<< HEAD +======= + fmt.Printf("debug: Returning msgjson=%s deadline=%d\n", encoded, deadline) +>>>>>>> ebeb409... Update RDB.Dequeue return encoded, deadline, nil } return "", 0, ErrNoProcessableTask