From 2f604d3e718246199b3741eb717b7d45ba4d4996 Mon Sep 17 00:00:00 2001
From: Michael Quigley <michael@quigley.com>
Date: Wed, 14 Jun 2023 15:31:11 -0400
Subject: [PATCH] amqp reconnect tweak

---
 controller/metrics/amqpSource.go | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/controller/metrics/amqpSource.go b/controller/metrics/amqpSource.go
index 54681602..0d9a0ab6 100644
--- a/controller/metrics/amqpSource.go
+++ b/controller/metrics/amqpSource.go
@@ -54,7 +54,7 @@ func (s *amqpSource) Start(events chan ZitiEventMsg) (join chan struct{}, err er
 
 		reconnect := false
 		for {
-			if reconnect {
+			if reconnect || s.errs == nil {
 				if err := s.reconnect(); err != nil {
 					logrus.Errorf("error reconnecting: %v", err)
 					continue
@@ -69,8 +69,8 @@ func (s *amqpSource) Start(events chan ZitiEventMsg) (join chan struct{}, err er
 						msg:  event,
 					}
 				}
-			case err := <-s.errs:
-				if err != nil {
+			case err, ok := <-s.errs:
+				if err != nil || !ok {
 					logrus.Error(err)
 					reconnect = true
 				}