CS

spiral-modules · Jan 21, 2019 · 2c921b5 · 2c921b5
1 parent 59a92b7
commit 2c921b5
Showing 1 changed file with 2 additions and 1 deletion.
diff --git 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