From c65b240b938a7a2051eedb2a46c112579c5e7c39 Mon Sep 17 00:00:00 2001 From: Brian Matheson Date: Tue, 16 Apr 2019 12:48:43 +0000 Subject: [PATCH] return 0 and use correct get modifier func --- queue.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/queue.go b/queue.go index 8885c5d..ad30e53 100644 --- a/queue.go +++ b/queue.go @@ -70,8 +70,9 @@ func (q *Queue) Poll() ([]*Pair, error) { func (q *Queue) Len() (int, error) { prefix := fmt.Sprintf("%s/", q.prefix) - resp, err := q.cli.GetPrefix(prefix, WithCountOnly()) - return resp, err + resp, err := q.cli.GetPrefix(prefix, etcd.WithCountOnly()) + fmt.Println("response to Len query is:", resp) + return 0, err } func (q *Queue) Watch(fn func(q *Queue, pair *Pair)) error {