Merge pull request #3781 from nats-io/neil/updateleafdelta

nats-io · Jan 12, 2023 · 4d52135 · 4d52135
2 parents d95c143 + 3b29ce4
commit 4d52135
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/leafnode.go b/server/leafnode.go
@@ -1857,7 +1857,7 @@ func (c *client) updateSmap(sub *subscription, delta int32) {
 
 	n := c.leaf.smap[key]
 	// We will update if its a queue, if count is zero (or negative), or we were 0 and are N > 0.
-	update := sub.queue != nil || n == 0 || n+delta <= 0
+	update := sub.queue != nil || (n <= 0 && n+delta > 0) || (n > 0 && n+delta <= 0)
 	n += delta
 	if n > 0 {
 		c.leaf.smap[key] = n