Throw exceptions on client

crucial-project · May 30, 2018 · 6fb5a3b · 6fb5a3b
1 parent 22f9a63
commit 6fb5a3b
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 4 deletions.
diff --git a/client/src/main/java/org/infinispan/creson/container/AbstractContainer.java b/client/src/main/java/org/infinispan/creson/container/AbstractContainer.java
@@ -56,7 +56,7 @@ public final Object getProxy(){
    public abstract void doExecute(Call call);
 
    protected Object execute(Call call)
-         throws InterruptedException, ExecutionException, java.util.concurrent.TimeoutException {
+         throws Throwable {
 
       if (log.isTraceEnabled())
          log.trace(this + " Executing "+call);
@@ -72,8 +72,8 @@ protected Object execute(Call call)
             attempts++;
             doExecute(call);
             ret = future.get(TTIMEOUT_TIME, TimeUnit.MILLISECONDS);
-            if (ret instanceof Throwable)
-               throw new ExecutionException((Throwable) ret);
+//            if (ret instanceof Throwable)
+//               throw new ExecutionException((Throwable) ret);
          }catch (TimeoutException e) {
             if (!future.isDone())
                log.warn(" Failed "+ call + " ("+e.getMessage()+")");
@@ -83,6 +83,8 @@ protected Object execute(Call call)
             }
             Thread.sleep(TTIMEOUT_TIME);
          }
+         if (ret instanceof Throwable)
+
       }
 
       registeredCalls.remove(call.getCallID());

diff --git a/client/src/main/java/org/infinispan/creson/container/BaseContainer.java b/client/src/main/java/org/infinispan/creson/container/BaseContainer.java
@@ -164,7 +164,7 @@ public String toString() {
     // internals
 
     private synchronized void open()
-            throws InterruptedException, ExecutionException, java.util.concurrent.TimeoutException {
+            throws Throwable {
 
         if (!isOpen) {