diff --git a/conn_pool.go b/conn_pool.go index 2c316779..06c6c22a 100644 --- a/conn_pool.go +++ b/conn_pool.go @@ -125,6 +125,7 @@ func (p *ConnPool) Release(conn *Conn) { } conn.channels = make(map[string]struct{}) } + conn.notifications = nil p.cond.L.Lock() if conn.IsAlive() {