From 02a7c13014d582ad197151c359b785ed8b382a60 Mon Sep 17 00:00:00 2001 From: Ken Hibino Date: Wed, 24 Feb 2021 11:22:05 -0800 Subject: [PATCH] Update RDB.Dequeue --- internal/rdb/rdb.go | 4 ++++ 1 file changed, 4 insertions(+) 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