No longer need to manually delete last message on replace

Signed-off-by: Neil Twigg <neil@nats.io>
nats-io · Jun 9, 2023 · f7380de · f7380de
1 parent 8f84574
commit f7380de
Showing 1 changed file with 1 addition and 5 deletions.
diff --git a/server/mqtt.go b/server/mqtt.go
@@ -3219,11 +3219,7 @@ func (c *client) mqttHandlePubRetain() {
 				sseq: smr.Sequence,
 			}
 			// Add/update the map
-			oldSeq := asm.handleRetainedMsg(key, rf)
-			// If this is a new message on the same subject, delete the old one.
-			if oldSeq != 0 {
-				asm.deleteRetainedMsg(oldSeq)
-			}
+			asm.handleRetainedMsg(key, rf)
 		} else {
 			c.mu.Lock()
 			acc := c.acc