Merge 848401a into a23dd57

nacos-group · May 25, 2023 · c6e087d · c6e087d
2 parents a23dd57 + 848401a
commit c6e087d
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 2 deletions.
diff --git a/clients/naming_client/naming_client.go b/clients/naming_client/naming_client.go
@@ -77,7 +77,9 @@ func NewNamingClient(nc nacos_client.INacosClient) (*NamingClient, error) {
 
 	naming.serviceProxy, err = NewNamingProxyDelegate(ctx, clientConfig, serverConfig, httpAgent, naming.serviceInfoHolder)
 
-	go NewServiceInfoUpdater(ctx, naming.serviceInfoHolder, clientConfig.UpdateThreadNum, naming.serviceProxy).asyncUpdateService()
+	if clientConfig.AsyncUpdateService {
+		go NewServiceInfoUpdater(ctx, naming.serviceInfoHolder, clientConfig.UpdateThreadNum, naming.serviceProxy).asyncUpdateService()
+	}
 	if err != nil {
 		return naming, err
 	}

diff --git a/common/constant/config.go b/common/constant/config.go
@@ -52,6 +52,7 @@ type ClientConfig struct {
 	LogSampling          *ClientLogSamplingConfig // the sampling config of log
 	LogRollingConfig     *ClientLogRollingConfig  // log rolling config
 	TLSCfg               TLSConfig                // tls Config
+	AsyncUpdateService   bool                     // open async update service by query
 }
 
 type ClientLogSamplingConfig struct {

diff --git a/common/remote/rpc/server_request_handler.go b/common/remote/rpc/server_request_handler.go
@@ -92,7 +92,7 @@ func (c *NamingPushRequestHandler) RequestReply(request rpc_request.IRequest, _
 	if ok {
 		c.ServiceInfoHolder.ProcessService(&notifySubscriberRequest.ServiceInfo)
 		return &rpc_response.NotifySubscriberResponse{
-			Response: &rpc_response.Response{ResultCode: constant.RESPONSE_CODE_SUCCESS},
+			Response: &rpc_response.Response{ResultCode: constant.RESPONSE_CODE_SUCCESS, Success: true},
 		}
 	}
 	return nil