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
 }
 

Reply via email to