我有一个 @Async
我要添加的方法 @Retry
但是当异常发生时,回退方法永远不会被执行。我还试图测试这个模拟,即抛出异常,但由于它从不转到fallback方法,因此它永远不会成功。
这是我的密码:
@Retry(name = "insertarOperacionPendienteService", fallbackMethod = "fallbackInsertarOperacionPendiente")
@Override
@Async
public CompletableFuture<String> insertarOperacionPendiente(final OperacionPendienteWeb operacionPendienteWeb) throws InterruptedException, ExecutionException {
StringBuilder debugMessage = new StringBuilder("[insertarOperacionPendiente] Operacion pendiente a insertar en BB.DD.: ").append(operacionPendienteWeb);
CompletableFuture<String> result = new CompletableFuture<>();
HttpEntity<List<OperacionPendienteWeb>> entity = new HttpEntity<>();
UriComponentsBuilder builder = UriComponentsBuilder.fromHttpUrl("url");
try {
rest.exchange(builder.toUriString(), HttpMethod.POST, entity, Void.class);
} catch (HttpClientErrorException | HttpServerErrorException e) {
result.completeExceptionally(e);
} catch (Exception e) {
result.completeExceptionally(e);
}
result.complete("OK");
return result;
}
public CompletableFuture<String> fallbackInsertarOperacionPendiente(Exception e) {
System.out.println("HI");
throw new InternalServerErrorDarwinException("Error al insertar la operacion pendiente.");
}
测试:
@Test(expected = InternalServerErrorDarwinException.class)
public void procesarOperacionPendienteKO1() throws InterruptedException, ExecutionException, ParseException {
when(rest.exchange(Mockito.anyString(),
Mockito.any(HttpMethod.class),
Mockito.any(HttpEntity.class),
Mockito.eq(Void.class)))
.thenThrow(new NullPointerException());
this.operacionesPendientesService.insertarOperacionPendiente(obtenerOperacionPendienteWeb()).get();
verify(rest, timeout(100).times(1)).exchange(Mockito.anyString(),
Mockito.any(HttpMethod.class),
Mockito.any(HttpEntity.class),
Mockito.eq(Void.class));
}
我错过什么了吗?
谢谢!
1条答案
按热度按时间ejk8hzay1#
您的代码如下所示:
所以在最后一行你总是把结果设置为完成!
更改为: