From 86d12b903deeefe13eeb140dd4fdb253eaefb619 Mon Sep 17 00:00:00 2001 From: Derek Collison Date: Wed, 3 Mar 2021 20:06:35 -0800 Subject: [PATCH] Fixed leaking info sub Signed-off-by: Derek Collison --- server/consumer.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/server/consumer.go b/server/consumer.go index d8f8bb7c..bf12981f 100644 --- a/server/consumer.go +++ b/server/consumer.go @@ -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)