X-Git-Url: https://git.teslayout.com/public/public/public/?a=blobdiff_plain;f=example%2Fdiameter%2Flauncher%2FMyDiameterEntity.hpp;h=554267b5a3f210d28b623c3abaff2b3f668c6304;hb=5a6cba5fde2b2f538a7515f8293cc0a8d9589dfa;hp=654a640e4de297a77877a71c1072318ffe3c3f05;hpb=129500a50678c43ff28fb0054d6197899b8c0b2c;p=anna.git diff --git a/example/diameter/launcher/MyDiameterEntity.hpp b/example/diameter/launcher/MyDiameterEntity.hpp index 654a640..554267b 100644 --- a/example/diameter/launcher/MyDiameterEntity.hpp +++ b/example/diameter/launcher/MyDiameterEntity.hpp @@ -11,9 +11,8 @@ // Project #include +#include -// Process -#include "ProgrammedAnswers.hpp" namespace anna { namespace diameter { @@ -25,19 +24,19 @@ namespace anna { class MyDiameterEntity : public anna::diameter::comm::Entity { - void eventResponse(const anna::diameter::comm::Response&) throw(anna::RuntimeException); - void eventRequest(anna::diameter::comm::ClientSession *, const anna::DataBlock&) throw(anna::RuntimeException); - void eventUnknownResponse(anna::diameter::comm::ClientSession *, const anna::DataBlock&) throw(anna::RuntimeException); - void eventDPA(anna::diameter::comm::ClientSession *, const anna::DataBlock&) throw(anna::RuntimeException); - - // Reimplementation - int readSocketId(const anna::diameter::comm::Message* message, int maxClientSessions) const throw(); + void eventRequestRetransmission(const anna::diameter::comm::ClientSession *, anna::diameter::comm::Message*) ; + void eventResponse(const anna::diameter::comm::Response&) noexcept(false); + void eventRequest(anna::diameter::comm::ClientSession *, const anna::DataBlock&) noexcept(false); + void eventUnknownResponse(anna::diameter::comm::ClientSession *, const anna::DataBlock&) noexcept(false); + void eventDPA(anna::diameter::comm::ClientSession *, const anna::DataBlock&) noexcept(false); public: - ProgrammedAnswers a_reactingAnswers; - void setProgrammedAnswersCodecEngine(anna::diameter::codec::Engine *codecEngine) throw() { a_reactingAnswers.setCodecEngine(codecEngine); } - ProgrammedAnswers *getReactingAnswers() throw() { return (ProgrammedAnswers *)&a_reactingAnswers; } + MyDiameterEntity() {;} + virtual ~MyDiameterEntity() {;} + + anna::diameter::codec::MessagesDeque a_reactingAnswers; + anna::diameter::codec::MessagesDeque *getReactingAnswers() { return (anna::diameter::codec::MessagesDeque*)&a_reactingAnswers; } }; #endif