Base protocol codec for comm::Engine. Supported retransmissions
[anna.git] / example / diameter / launcher / MyDiameterEntity.cpp
index 702ec56..ae4a3db 100644 (file)
@@ -78,7 +78,7 @@ throw(anna::RuntimeException) {
   if(localServer && (cid != anna::diameter::helpers::base::COMMANDID__Capabilities_Exchange_Request) /* don't forward CER */) {
     try {
       anna::diameter::comm::Message *msg = my_app.createCommMessage();
-      msg->updateEndToEnd(false); // end-to-end will be kept
+      msg->forwardEndToEnd(); // end-to-end will be kept
       msg->setBody(message);
       msg->setRequestClientSessionKey(clientSession->getKey());
       bool success = localServer->send(msg);
@@ -159,7 +159,7 @@ throw(anna::RuntimeException) {
     if(localServer && (request_cid != anna::diameter::helpers::base::COMMANDID__Capabilities_Exchange_Request) /* don't forward CEA */) {
       try {
         anna::diameter::comm::Message *msg = my_app.createCommMessage();
-        msg->updateEndToEnd(false); // end-to-end will be kept
+        msg->forwardEndToEnd(); // end-to-end will be kept
         msg->setBody(*message);
         bool success = localServer->send(msg, request->getRequestServerSessionKey());
         my_app.releaseCommMessage(msg);