Handle redis.ErrNil for Queues's latency (#32)

gojek · May 25, 2023 · 39a9c48 · 39a9c48
1 parent 075fbb8
commit 39a9c48
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/client.go b/client.go
@@ -279,6 +279,9 @@ func (c *Client) Queues() ([]*Queue, error) {
 	for _, s := range queues {
 		if s.Count > 0 {
 			b, err := redis.Bytes(conn.Receive())
+			if err == redis.ErrNil {
+				continue
+			}
 			if err != nil {
 				logError("client.queues.receive2", err)
 				return nil, err