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 } //同步调用