Fixed leaking info sub

Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2021-03-03 20:06:35 -08:00
parent 1b8fa93b18
commit 86d12b903d

View File

@@ -687,10 +687,12 @@ func (o *consumer) setLeader(isLeader bool) {
o.mu.Lock()
o.unsubscribe(o.ackSub)
o.unsubscribe(o.reqSub)
o.unsubscribe(o.infoSub)
o.ackSub = nil
o.reqSub = nil
o.infoSub = nil
if o.infoSub != nil {
o.srv.sysUnsubscribe(o.infoSub)
o.infoSub = nil
}
o.sendq = nil
if o.qch != nil {
close(o.qch)