From 2c921b559aceb01ff06d0fe4b75bc92e5ebea149 Mon Sep 17 00:00:00 2001
From: Wolfy-J <wolfy.jd@gmail.com>
Date: Mon, 21 Jan 2019 17:02:42 +0300
Subject: [PATCH] CS

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

diff --git a/broker/sqs/queue.go b/broker/sqs/queue.go
index dd54939..84fed17 100644
--- a/broker/sqs/queue.go
+++ b/broker/sqs/queue.go
@@ -97,11 +97,12 @@ func (q *queue) serve(s *sqs.SQS, tout time.Duration) {
 			if errored {
 				// reoccurring error
 				time.Sleep(tout)
-				continue
 			} else {
 				errored = true
 				q.report(err)
 			}
+
+			continue
 		}
 		errored = false