refine redo subscribe (#758)

nacos-group · Jun 2, 2024 · 61ecaa8 · 61ecaa8
1 parent 083c02f
commit 61ecaa8
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 8 deletions.
diff --git a/clients/naming_client/naming_grpc/connection_event_listener.go b/clients/naming_client/naming_grpc/connection_event_listener.go
@@ -52,6 +52,11 @@ func (c *ConnectionEventListener) OnDisConnect() {
 }
 
 func (c *ConnectionEventListener) redoSubscribe() {
+	grpcProxy, ok := c.clientProxy.(*NamingGrpcProxy)
+	if !ok {
+		logger.Error("redo subscribe clientProxy type error")
+		return
+	}
 	for _, key := range c.subscribes.Keys() {
 		info := strings.Split(key, constant.SERVICE_INFO_SPLITER)
 		var err error
@@ -61,15 +66,9 @@ func (c *ConnectionEventListener) redoSubscribe() {
 		} else {
 			service, err = c.clientProxy.Subscribe(info[1], info[0], "")
 		}
-
 		if err != nil {
 			logger.Warnf("redo subscribe service:%s faild:%+v", info[1], err)
-			return
-		}
-
-		grpcProxy, ok := c.clientProxy.(*NamingGrpcProxy)
-		if !ok {
-			return
+			continue
 		}
 		grpcProxy.serviceInfoHolder.ProcessService(&service)
 	}

diff --git a/common/constant/const.go b/common/constant/const.go
@@ -76,7 +76,7 @@ const (
 	KEY_BEAT                    = "beat"
 	KEY_DOM                     = "dom"
 	DEFAULT_CONTEXT_PATH        = "/nacos"
-	CLIENT_VERSION              = "Nacos-Go-Client:v2.2.4"
+	CLIENT_VERSION              = "Nacos-Go-Client:v2.2.6"
 	REQUEST_DOMAIN_RETRY_TIME   = 3
 	SERVICE_INFO_SPLITER        = "@@"
 	CONFIG_INFO_SPLITER         = "@@"