添加日志
This commit is contained in:
parent
3502013cce
commit
d6e7c512ad
@ -107,7 +107,7 @@ func (n *NatsService) subscribeRpc() error {
|
||||
return n.SubscribeCb(RpcTopic(n), func(m *nats.Msg) {
|
||||
var iMsg = &ipb.InternalMsg{}
|
||||
_ = proto.Unmarshal(m.Data, iMsg)
|
||||
log.DebugF("recv rpc msg:%v", iMsg.String())
|
||||
//log.DebugF("recv rpc msg:%v", iMsg.String())
|
||||
rsp, err := n.RpcProcessor.Dispatch(iMsg.RpcMsgId, iMsg)
|
||||
if err != nil {
|
||||
log.Error(err.Error())
|
||||
|
Loading…
x
Reference in New Issue
Block a user