Merge pull request #186 from frankfil/fix-example-client-channel-reco…

…nnection Fix Example Client not reconnecting
rabbitmq · Apr 5, 2023 · 90ec702 · 90ec702
2 parents f706086 + 46c4686
commit 90ec702
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/example_client_test.go b/example_client_test.go
@@ -204,6 +204,9 @@ func (client *Client) handleReInit(conn *amqp.Connection) bool {
 			select {
 			case <-client.done:
 				return true
+			case <-client.notifyConnClose:
+				client.logger.Println("Connection closed. Reconnecting...")
+				return false
 			case <-time.After(reInitDelay):
 			}
 			continue