mirrors/TarsCloud_TarsCpp
1
0
Fork 0
mirror of https://gitee.com/TarsCloud/TarsCpp.git synced 2024-12-22 22:16:38 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

TarsNotify.h add notify any app & server

Browse Source
This commit is contained in:
ruanshudong 2020-01-20 13:53:10 +08:00
parent c0ca4f3c92
commit f35ddf2b60
2 changed files with 26 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

53
servant/libservant/TarsNotify.cpp
View File

@ -101,34 +101,31 @@ void TarsRemoteNotify::notify(NOTIFYLEVEL level, const string &sMessage)
}
}
// void TarsRemoteNotify::report(const string &sMessage, const string & app, const string &serverName, const string &sNodeName)
// {
// try
// {
// if(_notifyPrx)
// {
// ReportInfo info;
// // info.eType = 0;
// info.sApp = app;
// info.sServer = serverName;
// info.sSet = "";
// info.sThreadId = "";//TC_Common::tostr(pthread_self());
// info.sMessage = sMessage;
// info.sNodeName = sNodeName;
// // info.eLevel = level;
// //_notifyPrx->async_notifyServer(NULL, _app + "." + _serverName, level, sMessage);
// _notifyPrx->async_reportNotifyInfo(NULL, info);
// }
// }
// catch(exception &ex)
// {
// TLOGERROR("TarsRemoteNotify::notify error:" << ex.what() << endl);
// }
// catch(...)
// {
// TLOGERROR("TarsRemoteNotify::notify unknown error" << endl);
// }
// }
void TarsRemoteNotify::report(const string &sMessage, const string & app, const string &serverName, const string &sNodeName)
{
try
{
if(_notifyPrx)
{
ReportInfo info;
// info.eType = 0;
info.sApp = app;
info.sServer = serverName;
info.sSet = "";
info.sMessage = sMessage;
info.sNodeName = sNodeName;
_notifyPrx->async_reportNotifyInfo(NULL, info);
}
}
catch(exception &ex)
{
TLOGERROR("TarsRemoteNotify::notify error:" << ex.what() << endl);
}
catch(...)
{
TLOGERROR("TarsRemoteNotify::notify unknown error" << endl);
}
}
}

2
servant/servant/TarsNotify.h
View File

@ -62,7 +62,7 @@ public:
* 指定通知到某个服务, 一定是异步上报的
* @param message
*/
// void report(const string &sMesage, const string & app, const string &serverName, const string &sNodeName);
void report(const string &sMesage, const string & app, const string &serverName, const string &sNodeName);
protected:
/**