diff --git a/lego/base/rpcx/service.go b/lego/base/rpcx/service.go index fc37ba59f..c06cb5b2e 100644 --- a/lego/base/rpcx/service.go +++ b/lego/base/rpcx/service.go @@ -165,10 +165,6 @@ func (this *RPCXService) RpcGo(ctx context.Context, servicePath string, serviceM ///servicePath = worker/[worker_1,worker_2] 表示随机选择[]里面的服务节点执行rpc方法 ///servicePath = worker/![worker_1,worker_2] 表示随机选择非[]里面的服务节点执行rpc方法 func (this *RPCXService) AcrossClusterRpcCall(ctx context.Context, clusterTag string, servicePath string, serviceMethod string, args interface{}, reply interface{}) (err error) { - if clusterTag == this.GetTag() { - err = fmt.Errorf("RPC equal clusterTag:%s ", clusterTag) - return - } return rpcx.AcrossClusterCall(ctx, clusterTag, servicePath, serviceMethod, args, reply) } @@ -180,10 +176,6 @@ func (this *RPCXService) AcrossClusterRpcCall(ctx context.Context, clusterTag st ///servicePath = worker/[worker_1,worker_2] 表示随机选择[]里面的服务节点执行rpc方法 ///servicePath = worker/![worker_1,worker_2] 表示随机选择非[]里面的服务节点执行rpc方法 func (this *RPCXService) AcrossClusterRpcGo(ctx context.Context, clusterTag string, servicePath string, serviceMethod string, args interface{}, reply interface{}) (call *client.Call, err error) { - if clusterTag == this.GetTag() { - err = fmt.Errorf("RPC equal clusterTag:%s ", clusterTag) - return - } return rpcx.AcrossClusterGo(ctx, clusterTag, servicePath, serviceMethod, args, reply, nil) } @@ -195,10 +187,6 @@ func (this *RPCXService) AcrossClusterRpcGo(ctx context.Context, clusterTag stri ///servicePath = worker/[worker_1,worker_2] 表示随机选择[]里面的服务节点执行rpc方法 ///servicePath = worker/![worker_1,worker_2] 表示随机选择非[]里面的服务节点执行rpc方法 func (this *RPCXService) AcrossClusterBroadcast(ctx context.Context, clusterTag string, servicePath string, serviceMethod string, args interface{}, reply interface{}) (err error) { - if clusterTag == this.GetTag() { - err = fmt.Errorf("RPC equal clusterTag:%s ", clusterTag) - return - } return rpcx.AcrossClusterBroadcast(ctx, clusterTag, servicePath, serviceMethod, args, reply) }