From f126833315d68598a967e4518736321c1119fb6d Mon Sep 17 00:00:00 2001
From: liwei1dao <liwei1dao@gmail.com>
Date: Thu, 20 Oct 2022 11:17:37 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A4=84=E7=90=86rpcx=E5=8F=8C=E5=90=91?=
 =?UTF-8?q?=E9=80=9A=E4=BF=A1=E5=A4=84=E7=90=86=E6=B5=81=E6=89=BE=E4=B8=8D?=
 =?UTF-8?q?=E5=88=B0=E7=9A=84=E6=83=85=E5=86=B5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 lego/sys/rpcx/rpcx.go | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/lego/sys/rpcx/rpcx.go b/lego/sys/rpcx/rpcx.go
index f24934a09..8e3476927 100644
--- a/lego/sys/rpcx/rpcx.go
+++ b/lego/sys/rpcx/rpcx.go
@@ -38,7 +38,7 @@ type RPCX struct {
 func (this *RPCX) Start() (err error) {
 	this.service.Start()
 	this.client.Start()
-	
+
 	return
 }
 
@@ -54,16 +54,20 @@ func (this *RPCX) GetServiceTags() []string {
 }
 func (this *RPCX) RegisterFunction(fn interface{}) (err error) {
 	this.service.RegisterFunction(fn)
+	this.client.RegisterFunction(fn)
 	return
 }
 
 func (this *RPCX) RegisterFunctionName(name string, fn interface{}) (err error) {
 	this.service.RegisterFunctionName(name, fn)
+	this.client.RegisterFunctionName(name, fn)
 	return
 }
 
 func (this *RPCX) UnregisterAll() (err error) {
-	return this.service.UnregisterAll()
+	err = this.service.UnregisterAll()
+	err = this.client.UnregisterAll()
+	return
 }
 
 //同步调用