before cnx.close, the stat need change to connectionClosing

apache · Dec 3, 2021 · e624f23 · e624f23
1 parent 7ab9b4c
commit e624f23
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pulsar/internal/connection.go b/pulsar/internal/connection.go
@@ -858,13 +858,14 @@ func (c *connection) Close() {
 		c.Lock()
 		cnx := c.cnx
 		c.Unlock()
-		c.changeState(connectionClosed)
+		c.changeState(connectionClosing)
 
 		if cnx != nil {
 			_ = cnx.Close()
 		}
 
 		close(c.closeCh)
+                c.changeState(connectionClosed)
 
 		listeners := make(map[uint64]ConnectionListener)
 		c.listenersLock.Lock()