From b154c3d957f08c0c80e7798679e5f577116c2a71 Mon Sep 17 00:00:00 2001 From: Matthias Hanel Date: Fri, 2 Apr 2021 17:18:05 -0400 Subject: [PATCH] [Fixed] remote subscription leak for leafnodes caused by auto unsubscribe Signed-off-by: Matthias Hanel --- server/client.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/server/client.go b/server/client.go index 14ed8ec2..dac5d8d9 100644 --- a/server/client.go +++ b/server/client.go @@ -2976,6 +2976,7 @@ func (c *client) deliverMsg(sub *subscription, subject, reply, mh, msg []byte, g defer srv.gatewayUpdateSubInterest(client.acc.Name, sub, -1) } defer srv.updateRouteSubscriptionMap(client.acc, sub, -1) + defer srv.updateLeafNodes(client.acc, sub, -1) } defer client.unsubscribe(client.acc, sub, true, true) } else if sub.nm > sub.max { @@ -2987,6 +2988,7 @@ func (c *client) deliverMsg(sub *subscription, subject, reply, mh, msg []byte, g if srv.gateway.enabled { srv.gatewayUpdateSubInterest(client.acc.Name, sub, -1) } + srv.updateLeafNodes(client.acc, sub, -1) } return false }