diff --git a/functional_test.go b/functional_test.go index 3607fd145..82ee8ee19 100644 --- a/functional_test.go +++ b/functional_test.go @@ -228,7 +228,7 @@ mainLoop: } for _, broker := range brokers { err := broker.Open(client.Config()) - if err != nil { + if err != nil && err != ErrAlreadyConnected { client.Close() continue retryLoop }