Remove notifications when releasing Conn to Pool
This commit is contained in:
@@ -125,6 +125,7 @@ func (p *ConnPool) Release(conn *Conn) {
|
|||||||
}
|
}
|
||||||
conn.channels = make(map[string]struct{})
|
conn.channels = make(map[string]struct{})
|
||||||
}
|
}
|
||||||
|
conn.notifications = nil
|
||||||
|
|
||||||
p.cond.L.Lock()
|
p.cond.L.Lock()
|
||||||
if conn.IsAlive() {
|
if conn.IsAlive() {
|
||||||
|
|||||||
Reference in New Issue
Block a user