From e20ba0aeec5c1211650c32d243edaedecbd65b54 Mon Sep 17 00:00:00 2001
From: Alok Kumar Singh <alok.singh@practo.com>
Date: Tue, 22 Sep 2020 09:18:18 +0000
Subject: [PATCH] Return if err in getting client

---
 pkg/queue/beanstalk.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/pkg/queue/beanstalk.go b/pkg/queue/beanstalk.go
index c4c6e300..b8cc9150 100644
--- a/pkg/queue/beanstalk.go
+++ b/pkg/queue/beanstalk.go
@@ -325,7 +325,8 @@ func (b *Beanstalk) waitForShortPollInterval() {
 func (b *Beanstalk) reestablishConn(queueURI string) {
 	client, err := b.getClient(queueURI)
 	if err != nil {
-		klog.Error(err)
+		klog.Errorf("Could not reestablish conn, err:%v\n", err)
+		return
 	}
 
 	err = client.reestablishConn()