-a/src/DAF/AE/AEPing.cc
+b/src/DAF/AE/AEPing.cc
 ...
 const char* PAR_RATE            = "rate";
 const char* PAR_DSTAPNAME       = "dstApName";
 const char* PAR_DSTAPINSTANCE   = "dstApInstance";
 const char* PAR_DSTAENAME       = "dstAeName";
 const char* PAR_DSTAEINSTANCE   = "dstAeInstance";
+const char* VAL_MODULEPATH      = "getFullPath()";
 AEPing::AEPing() {
+}
 AEPing::~AEPing() {
 ...
+}
 void AEPing::preparePing() {
     //Schedule Data transfer
     for (int i = 0; i < rate && pingAt + i < stopAt; i++) {
-        std::stringstream ss;
+        std::ostringstream ss;
         ss << MSG_PING << i;
         cMessage* m2 = new cMessage(ss.str().c_str());
         scheduleAt(pingAt + i, m2);
+    }
+}
 ...
     dstApName     = this->par(PAR_DSTAPNAME).stringValue();
     dstApInstance = this->par(PAR_DSTAPINSTANCE).stringValue();
     dstAeName     = this->par(PAR_DSTAENAME).stringValue();
     dstAeInstance = this->par(PAR_DSTAEINSTANCE).stringValue();
-    //Flow
-    APNamingInfo src = this->getApni();
-    APNamingInfo dst = APNamingInfo( APN(this->dstApName), this->dstApInstance,
-                                     this->dstAeName, this->dstAeInstance);
-    Flow fl = Flow(src, dst);
-    fl.setQosParameters(this->getQoSRequirements());
-    //Insert it to the Flows ADT
-    insertFlow(fl);
     //Schedule AllocateRequest
     if (startAt > 0)
         prepareAllocateRequest();
     //Schedule Data transfer
     if (pingAt > 0)
         preparePing();
     //Schedule DeallocateRequest
     if (stopAt > 0)
         prepareDeallocateRequest();
+    myPath = this->getFullPath();
     //Watchers
     WATCH_LIST(flows);
+}
 void AEPing::handleSelfMessage(cMessage *msg) {
     //EV << flows.back().info() << endl;
-    if ( !strcmp(msg->getName(), "StartCommunication") ) {
+    if ( !strcmp(msg->getName(), TIM_START) ) {
-        //signalizeAllocateRequest(&flows.back());
         //FIXME: Vesely - last flow in a list?!
+        //Flow
+        APNamingInfo src = this->getApni();
+        APNamingInfo dst = APNamingInfo( APN(this->dstApName), this->dstApInstance,
+                                         this->dstAeName, this->dstAeInstance);
+        Flow fl = Flow(src, dst);
+        fl.setQosParameters(this->getQoSRequirements());
+        //Insert it to the Flows ADT
+        insertFlow(fl);
-        Irm->receiveAllocationRequest(&flows.back());
+        sendAllocationRequest(&flows.back());
+    }
-    else if ( !strcmp(msg->getName(), "StopCommunication") )
+    else if ( !strcmp(msg->getName(), TIM_STOP) ) {
+        //FIXME: Vesely - last flow in a list?!
-        //signalizeDeallocateRequest(&flows.back());
+        sendDeallocationRequest(&flows.back());
-        //Irm->receiveDeallocationRequest(&flows.back());
+    }
-        EV << "StopCommunication";
-    else if ( strstr(msg->getName(), "PING") ) {
+    else if ( strstr(msg->getName(), MSG_PING) ) {
-        //TODO: Vesely - Send M_READ
+        //Create PING messsage
-        std::stringstream ss;
+        CDAP_M_Read* ping = new CDAP_M_Read(VAL_MODULEPATH);
-        ss << "M_READ(" << msg->getName() << ")";
+        object_t obj;
-        cMessage* ping = new cMessage(ss.str().c_str());
+        obj.objectName = VAL_MODULEPATH;
-        send(ping , "dataIo$o", 0);
+        obj.objectClass = "string";
+        obj.objectInstance = -1;
+        obj.objectVal = (cObject*)(&myPath);
+        ping->setObject(obj);
+        //Send message
+        sendData(&flows.back(), ping);
+    }
     else
         EV << this->getFullPath() << " received unknown self-message " << msg->getName();
     delete(msg);
+}
 ...
 void AEPing::handleMessage(cMessage *msg)
+{
     if ( msg->isSelfMessage() )
             this->handleSelfMessage(msg);
+}
+void AEPing::processMRead(CDAPMessage* msg) {
+    CDAP_M_Read* msg1 = check_and_cast<CDAP_M_Read*>(msg);
+    EV << "Received M_Read";
+    object_t object = msg1->getObject();
+    EV << " with object '" << object.objectClass << "'" << endl;
+    if ( strstr(object.objectName.c_str(), VAL_MODULEPATH) ) {
+        std::string* source = (std::string*)(object.objectVal);
+        std::ostringstream os;
+        os << "Ping requested by " <<  *source << endl;
+        bubble(os.str().c_str());
+        EV << os.str().c_str();
+        //Create PING response
+        CDAP_M_Read_R* pong = new CDAP_M_Read_R(VAL_MODULEPATH);
+        object_t obj;
+        obj.objectName = VAL_MODULEPATH;
+        obj.objectClass = "string";
+        obj.objectInstance = -1;
+        obj.objectVal = (cObject*)(&myPath);
+        pong->setObject(obj);
+        sendData(&flows.back(), pong);
+    }
+}
+void AEPing::processMReadR(CDAPMessage* msg) {
+    CDAP_M_Read_R* msg1 = check_and_cast<CDAP_M_Read_R*>(msg);
+    EV << "Received M_Read_R";
+    object_t object = msg1->getObject();
+    EV << " with object '" << object.objectClass << "'" << endl;
+    if ( strstr(object.objectName.c_str(), VAL_MODULEPATH) ) {
+        std::string* source = (std::string*)(object.objectVal);
+        std::ostringstream os;
+        os << "Ping replied by " <<  *source << endl;
+        bubble(os.str().c_str());
+        EV << os.str().c_str();
+    }
+}