From b06327602c797f6edec97dc38c3beb27fa289701 Mon Sep 17 00:00:00 2001 From: liuxiaobo <1224730913@qq.com> Date: Thu, 29 May 2025 13:15:54 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E6=B3=A8=E5=86=8Crpc?= =?UTF-8?q?=E6=B6=88=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- service/natsService.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/service/natsService.go b/service/natsService.go index 18bf0d8..77e5bdf 100644 --- a/service/natsService.go +++ b/service/natsService.go @@ -143,7 +143,7 @@ func (s *NatsService) Call(rpcTopic string, msg *ipb.InternalMsg, cb func(msg *i if err != nil { return err } - s.rpcProcessor.RegisterMessage(msg.RetRpcMsgId, ipb.InternalMsg{}, cb) + s.RegisterRpcMessage(msg.RetRpcMsgId, cb) return nil }