Как бросить исключение из актера akka? - PullRequest
Новая
       7

Как бросить исключение из актера akka?

0 голосов
/ 06 февраля 2019

У меня есть приложение весенней загрузки, которое я пытаюсь интегрировать с akka.Для большинства конечных точек я полагаюсь на пружинную загрузку, встроенную в механизм RuntimeException, но актеры akka не позволяют генерировать исключения для каких-либо мыслей?

у меня есть этот помощник для вызова других служб: 

public ResponseEntity<R> callService(String address
        , MultiValueMap<String, String> headers
        , B body
        , HttpMethod httpMethod
        , ParameterizedTypeReference<R> parameterizedTypeReference
        , ExceptionHandlerCustom exceptionHandlerCustom) {
    try {
        HttpEntity<B> request = new HttpEntity<>(body, headers);
        return restTemplate.exchange(address
                , httpMethod
                , request
                , parameterizedTypeReference);
    } catch (Exception e) {
        if (e instanceof HttpStatusCodeException) {
            HttpStatusCodeException exception = (HttpStatusCodeException) e;
            Gson gson = new Gson();
            Response<String> errorResponse =
                    gson.fromJson(exception.getResponseBodyAsString(), new TypeToken<Response<String>>(){}.getType());
            if (exception.getStatusCode().equals(HttpStatus.BAD_REQUEST)) {
                throw new BadRequestException(errorResponse.getMessage());
            } else if (exception.getStatusCode().equals(HttpStatus.UNAUTHORIZED)) {
                throw new UnauthorizedException("not authorized");
            } else if (exception.getStatusCode().equals(HttpStatus.INTERNAL_SERVER_ERROR)) {
                e.printStackTrace();
                throw new InternalServerErrorException();
            } else if (exceptionHandlerCustom != null) {
                exceptionHandlerCustom.handle(e);
            }else
                e.printStackTrace();
        }
        throw e;
    }
}

У меня есть актер, который вызывает этот метод, и я хочу повторно выбросить исключение, когда это произойдет (я знаю, что жизненный цикл актера не может быть прерван)

все мои исключения такие: 

@ResponseStatus(HttpStatus.NOT_FOUND)
public class NotFoundException extends RuntimeException {
    public NotFoundException(String message) {
        super(message);
    }
}

и в моем актере у меня есть этот метод: 

@Override
    public Receive createReceive() {
    return receiveBuilder()
            .match(CheckUserIdAndProvidedToken.class, message -> {
                getSender().tell(tokenCheckService.checkUserIdAndProvidedToken(message.getToken()
                        , message.getId()), getSelf());
            })
            .build();
}

и в сервисе я называю это так: 

Future<Object> futureOfCheck = ask(checker, new         
TokenCheckActor.CheckUserIdAndProvidedToken(id, token), timeout);

и когда исключениепроисходит, я люблю бросать это клиентам (исключение весенней загрузки в формате json): 

{
    "timestamp": "2019-02-06T06:42:26.740+0000",
    "status": 404,
    "error": "Not Found",
    "message": "user not found",
    "path": "/xxxx/yyy/ssss"
}

1 Ответ

0 голосов
/ 06 февраля 2019

Можно передать Exceptions через шаблон запроса.Это описано в разделе ask-send-and-receive-future документа akka.

В итоге, перехватите исключение в методе receive, оберните его Failure и отправьте отправителю. 

try {
  String result = operation();
  getSender().tell(result, getSelf());
} catch (Exception e) {
  getSender().tell(new akka.actor.Status.Failure(e), getSelf());
  throw e;
}
...