fix: topic publshInfo and subscribeInfo not update (#1084)

apache · Aug 3, 2023 · 7eedaf9 · 7eedaf9
1 parent e22605a
commit 7eedaf9
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/internal/client.go b/internal/client.go
@@ -405,6 +405,8 @@ func GetOrNewRocketMQClient(option ClientOptions, callbackCh chan interface{}) R
 			return res
 		})
 	}
+	// bundle this client to namesrv
+	client.GetNameSrv().(*namesrvs).bundleClient = client
 	return client
 }