commit e471132053b0c757f84fef9666a3d08dc6064757
author Martin Veith <veithm@apache.org> Fri May 15 15:06:30 2015 +0000
committer Martin Veith <veithm@apache.org> Fri May 15 15:06:30 2015 +0000
tree 552785fdde6bbfc2dc1d54987cb8e349be539e5a
parent 2d69ad1dc9eb661dc7421aa7ad6900af821c4843

Add sessionDown notification in EtchStubBase

In case an exception occurs during the execution of an execution
helper, the session down event gets send to the user.

Change-Id: I74e91fecf664f129c2edd4767175f0e9d975f4d6

git-svn-id: https://svn.apache.org/repos/asf/etch/trunk@1679587 13f79535-47bb-0310-9956-ffa450edef68

binding-cpp/runtime/include/support/EtchStubBase.h

diff --git a/binding-cpp/runtime/include/support/EtchStubBase.h b/binding-cpp/runtime/include/support/EtchStubBase.h
index 09a16c3..bdb19ff 100644
--- a/binding-cpp/runtime/include/support/EtchStubBase.h
+++ b/binding-cpp/runtime/include/support/EtchStubBase.h
@@ -154,7 +154,7 @@
       res = mQueuedPool->add(runnable);
       if (res != ETCH_OK) {
         //CAPU_LOG_ERROR(mRuntime->getLogger(), "EtchStubBase", "Error while adding runnable to pool");
-        sessionNotify(NULL); //TODO Exception Handling
+        sessionNotify(new EtchString(EtchSession::DOWN())); //TODO Exception Handling
       }
       return res;
     case FREE:
@@ -163,7 +163,7 @@
       res = mFreePool->add(runnable);
       if (res != ETCH_OK) {
         //CAPU_LOG_ERROR(mRuntime->getLogger(), "EtchStubBase", "Error while adding runnable to pool");
-        sessionNotify(NULL); //TODO Exception Handling
+        sessionNotify(new EtchString(EtchSession::DOWN())); //TODO Exception Handling
       }
       return res;
     case NONE:
@@ -171,12 +171,12 @@
       res = helper->run(this, mSvc, mObj, sender, msg);
       if (res != ETCH_OK) {
         //CAPU_LOG_ERROR(mRuntime->getLogger(), "EtchStubBase", "Error while executing function");
-        sessionNotify(NULL); //TODO Exception Handling
+        sessionNotify(new EtchString(EtchSession::DOWN())); //TODO Exception Handling
       }
       return res;
     default:
       //  throw new IllegalArgumentException("unknown async mode "+type.getAsyncMode());
-      sessionNotify(NULL); //TODO Exception Handling
+      sessionNotify(new EtchString(EtchSession::DOWN())); //TODO Exception Handling
       return ETCH_OK;
   }
 }