Browse Source

update

storage-in-realtime
zhaohe 12 months ago
parent
commit
dd5aed32f8
  1. 9
      appsrc/baseservice/front_msg_processer/front_msg_processer.cpp

9
appsrc/baseservice/front_msg_processer/front_msg_processer.cpp

@ -74,8 +74,10 @@ void FrontMsgProcesser::processMsg(shared_ptr<MsgProcessContext> cxt) {
logger->info("call: {}->({})", fn, param);
if (fn == "FNScheduler.geFnList") {
cxt->receipt["ackcode"] = 0;
cxt->receipt["rely"] = geFnList();
cxt->receipt["ackcode"] = 0;
cxt->receipt["rely"] = geFnList();
cxt->receipt["fromClass"] = "FNScheduler";
cxt->receipt["fromFn"] = "geFnList";
return;
}
@ -99,6 +101,9 @@ void FrontMsgProcesser::processMsg(shared_ptr<MsgProcessContext> cxt) {
cxt->receipt["ackcode"] = e.ecode();
cxt->receipt["message"] = fmt::format("[{}],{}", ecode2str(cxt->receipt["ackcode"]), e.what());
}
cxt->receipt["fromClass"] = m_msgProcesserMap[key]->className;
cxt->receipt["fromFn"] = m_msgProcesserMap[key]->fnName;
} else {
logger->error("unknown command: {}", key);
cxt->receipt["ackcode"] = err::kappe_cmd_not_support;

Loading…
Cancel
Save