diff --git a/broker.go b/broker.go
index 7ec3022b3..71866ed66 100644
--- a/broker.go
+++ b/broker.go
@@ -260,6 +260,7 @@ func (b *Broker) Open(conf *Config) error {
 			b.connErr = b.authenticateViaSASLv1()
 			if b.connErr != nil {
 				close(b.responses)
+				<-b.done
 				err = b.conn.Close()
 				if err == nil {
 					DebugLogger.Printf("Closed connection to broker %s\n", b.addr)