X-Git-Url: https://git.teslayout.com/public/public/public/?a=blobdiff_plain;f=example%2Fdiameter%2Flauncher%2FMyDiameterEntity.cpp;h=5e78ab32429407fa79a01c001fdfc9c60b5aad39;hb=97a93101fb874a3237083d72c6d6f8c8df8dcfba;hp=6c1244b55710a92cbb8583ad595ce1dac5fcdad4;hpb=e80e62a5cf9aacad1a9551c68c432147ef98cd29;p=anna.git diff --git a/example/diameter/launcher/MyDiameterEntity.cpp b/example/diameter/launcher/MyDiameterEntity.cpp index 6c1244b..5e78ab3 100644 --- a/example/diameter/launcher/MyDiameterEntity.cpp +++ b/example/diameter/launcher/MyDiameterEntity.cpp @@ -20,7 +20,7 @@ #include #include #include -#include +#include #include @@ -33,7 +33,7 @@ void MyDiameterEntity::eventRequestRetransmission(const anna::diameter::comm::Cl // Performance stats: Launcher& my_app = static_cast (anna::app::functions::getApp()); - RealmNode * my_node = my_app.getRealmNode(getEngine()->getRealm()); + OriginHost * my_node = my_app.getOriginHost(getEngine()->getOriginHost()); // CommandId: anna::diameter::CommandId cid = anna::diameter::codec::functions::getCommandId(request->getBody()); LOGDEBUG @@ -99,7 +99,7 @@ throw(anna::RuntimeException) { LOGMETHOD(anna::TraceMethod tm("launcher::MyDiameterEntity", "eventRequest", ANNA_FILE_LOCATION)); // Performance stats: Launcher& my_app = static_cast (anna::app::functions::getApp()); - RealmNode * my_node = my_app.getRealmNode(getEngine()->getRealm()); + OriginHost * my_node = my_app.getOriginHost(getEngine()->getOriginHost()); // CommandId: anna::diameter::CommandId cid = anna::diameter::codec::functions::getCommandId(message); @@ -183,7 +183,7 @@ void MyDiameterEntity::eventResponse(const anna::diameter::comm::Response &respo throw(anna::RuntimeException) { LOGMETHOD(anna::TraceMethod tm("launcher::MyDiameterEntity", "eventResponse", ANNA_FILE_LOCATION)); Launcher& my_app = static_cast (anna::app::functions::getApp()); - RealmNode * my_node = my_app.getRealmNode(getEngine()->getRealm()); + OriginHost * my_node = my_app.getOriginHost(getEngine()->getOriginHost()); anna::diameter::comm::ClassCode::_v code = response.getClassCode(); anna::diameter::comm::Response::ResultCode::_v result = response.getResultCode(); anna::diameter::comm::Message* request = const_cast(response.getRequest()); @@ -279,7 +279,7 @@ throw(anna::RuntimeException) { LOGMETHOD(anna::TraceMethod tm("launcher::MyDiameterEntity", "eventUnknownResponse", ANNA_FILE_LOCATION)); // Performance stats: Launcher& my_app = static_cast (anna::app::functions::getApp()); - RealmNode * my_node = my_app.getRealmNode(getEngine()->getRealm()); + OriginHost * my_node = my_app.getOriginHost(getEngine()->getOriginHost()); // CommandId: anna::diameter::CommandId cid = anna::diameter::codec::functions::getCommandId(message); LOGDEBUG @@ -302,7 +302,7 @@ throw(anna::RuntimeException) { LOGMETHOD(anna::TraceMethod tm("launcher::MyDiameterEntity", "eventDPA", ANNA_FILE_LOCATION)); // Performance stats: Launcher& my_app = static_cast (anna::app::functions::getApp()); - RealmNode * my_node = my_app.getRealmNode(getEngine()->getRealm()); + OriginHost * my_node = my_app.getOriginHost(getEngine()->getOriginHost()); // CommandId: anna::diameter::CommandId cid = anna::diameter::codec::functions::getCommandId(message); LOGDEBUG @@ -318,4 +318,7 @@ throw(anna::RuntimeException) { // Write reception if(my_node->logEnabled()) my_node->writeLogFile(message, "recvfe", clientSession->asString()); + + // Testing: + TestManager::instantiate().receiveMessage(message, my_node, clientSession); }