Update rpc_client.go

nacos-group · Jan 24, 2025 · 8743556 · 8743556
1 parent 0dfd3a6
commit 8743556
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/common/remote/rpc/rpc_client.go b/common/remote/rpc/rpc_client.go
@@ -112,6 +112,7 @@ type RpcClient struct {
 	mux                         *sync.Mutex
 	clientAbilities             rpc_request.ClientAbilities
 	Tenant                      string
+	ReconnectCallbackListen     func()
 }
 
 type ServerRequestHandlerMapping struct {
@@ -448,6 +449,7 @@ func (r *RpcClient) reconnect(serverInfo ServerInfo, onRequestFail bool) {
 			r.currentConnection = connectionNew
 			atomic.StoreInt32((*int32)(&r.rpcClientStatus), (int32)(RUNNING))
 			r.notifyConnectionChange(CONNECTED)
+			r.ReconnectCallbackListen()
 			return
 		}
 		if r.isShutdown() {