diff --git a/pubsub.go b/pubsub.go
index 6393d8a..b9d5c60 100644
--- a/pubsub.go
+++ b/pubsub.go
@@ -52,6 +52,7 @@ func (c *PubSub) conn() (*pool.Conn, bool, error) {
 	}
 
 	if err := c.resubscribe(cn); err != nil {
+		_ = c.base.connPool.CloseConn(cn)
 		return nil, false, err
 	}