AskTimeoutExceptionを処理する方法は？

Question

私は時間のかかる何かをするために俳優に電話をかけようとしています。 発信者がタイマーを5秒で設定しました。しかし、try/catchでタイムアウト例外を処理することはできません。あなたが行うことができます

return async(Akka.asPromise(ask(myActor, "hello", uploadImageTimeout)).map(new Function<Object, Result>() { 
@Override 
public Result apply(Object response) { 
return ok("Done"); 
} 
})); 

Answer 1

ことの一つは、右アッカの将来の内側例外から「回復」することです：

return async(Akka.asPromise(ask(myActor, "hello", uploadImageTimeout).recover(
    new Recover<Object>() { 
     @Override 
     public Object recover(Throwable t) throws Throwable { 
      if(t instanceof AskTimeoutException) { 
       Logger.error("Got exception: ", t); 
       return internalServerError("Timeout"); 
      } 
      else { 
       Logger.error("Got exception: ", t); 
       return internalServerError("Got Exception: " + t.getMessage()); 
      } 
     } 
    }) 
).map(new Function<Object, Result>() { 
    @Override 
    public Result apply(Object response) { 
     if(response instanceof Result) { 
      // Result objects are returned by the recover handler above 
      return (Result)response; 
     } 
     else { 
      return ok(doSomethingWithResponse(response)); 
     } 
    } 
})); 

Answer 2

プレイ2.2.1（およびアッカ2.2）を使用して、溶液中の軽微な変更が必要です。ソースコードテストは、回答を見つけるのに最適なサイトです。私はここに私を見つけましたhttps://github.com/akka/akka/blob/f1edf789798dc02dfa37d3301d7712736c964ab1/akka-docs/rst/java/code/docs/future/FutureDocTest.java

@Test 
public void useRecover() throws Exception { 
    //#recover 
    final ExecutionContext ec = system.dispatcher(); 
    Future<Integer> future = future(new Callable<Integer>() { 
     public Integer call() { 
     return 1/0; 
     } 
    }, ec).recover(new Recover<Integer>() { 
     public Integer recover(Throwable problem) throws Throwable { 
     if (problem instanceof ArithmeticException) 
      return 0; 
     else 
      throw problem; 
     } 
    }, ec); 

    future.onSuccess(new PrintResult<Integer>(), system.dispatcher()); 
    //#recover 
    int result = Await.result(future, Duration.create(5, SECONDS)); 
    assertEquals(result, 0); 
    }