From 7eedaf948c6076c716972724782f4837e1f9caa6 Mon Sep 17 00:00:00 2001 From: redlsz <103550934+redlsz@users.noreply.github.com> Date: Thu, 3 Aug 2023 15:41:38 +0800 Subject: [PATCH] fix: topic publshInfo and subscribeInfo not update (#1084) --- internal/client.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/internal/client.go b/internal/client.go index 1321da97..6f27f5e8 100644 --- 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 }