From e8de74f76d87c3c03833d2c8d7721eb80a420681 Mon Sep 17 00:00:00 2001 From: withchao <993506633@qq.com> Date: Wed, 11 Jan 2023 15:33:32 +0800 Subject: [PATCH] group rpc --- pkg/common/middleware/rpc.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pkg/common/middleware/rpc.go b/pkg/common/middleware/rpc.go index c1282bbb4..75b94d64e 100644 --- a/pkg/common/middleware/rpc.go +++ b/pkg/common/middleware/rpc.go @@ -62,9 +62,9 @@ func RpcServerInterceptor(ctx context.Context, req interface{}, info *grpc.Unary } func RpcClientInterceptor(ctx context.Context, method string, req, reply interface{}, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) (err error) { - if cc == nil { - return utils.Wrap(constant.ErrRpcConn, "") - } + //if cc == nil { + // return utils.Wrap(constant.ErrRpcConn, "") + //} operationID, ok := ctx.Value("operationID").(string) if !ok { return utils.Wrap(constant.ErrArgs, "ctx missing operationID")