Skip to content

Commit b4e8157

Browse files
committed
do not delete topic from msgRouter after unsubscribe
1 parent 88c4622 commit b4e8157

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

client.go

+3-3
Original file line numberDiff line numberDiff line change
@@ -639,9 +639,9 @@ func (c *client) Unsubscribe(topics ...string) Token {
639639
copy(unsub.Topics, topics)
640640

641641
c.oboundP <- &PacketAndToken{p: unsub, t: token}
642-
for _, topic := range topics {
643-
c.msgRouter.deleteRoute(topic)
644-
}
642+
// for _, topic := range topics {
643+
// c.msgRouter.deleteRoute(topic)
644+
// }
645645

646646
DEBUG.Println(CLI, "exit Unsubscribe")
647647
return token

0 commit comments

Comments
 (0)