Как обращаться с 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

Использование Play 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); 
    }