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 }