This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git
The following commit(s) were added to refs/heads/master by this push:
new 7eedaf9 fix: topic publshInfo and subscribeInfo not update (#1084)
7eedaf9 is described below
commit 7eedaf948c6076c716972724782f4837e1f9caa6
Author: redlsz <[email protected]>
AuthorDate: Thu Aug 3 15:41:38 2023 +0800
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 1321da9..6f27f5e 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
}