Details
-
Improvement
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
-
None
Description
Problem.
In case of business logic exceptions thrown from within raft listeners it's recommended to use
clo.result(throwable)
Such throwable is propagated to raft client in ActionResponse container and later on competes client future in common but not an exceptional way (which is a problem):
return fut.thenApply(resp -> (R) resp.result());
@Override public <R> CompletableFuture<R> run(Command cmd) {
Peer leader = this.leader;
if (leader == null)
return refreshLeader().thenCompose(res -> run(cmd));
ActionRequest req = factory.actionRequest().command(cmd).groupId(groupId).readOnlySafe(true).build();
CompletableFuture<ActionResponse> fut = new CompletableFuture<>();
sendWithRetry(leader, req, currentTimeMillis() + timeout, fut);
return fut.thenApply(resp -> (R) resp.result());
}
Client future usually have some specific generic type, for example CompletableFuture<Void>, that doesn't match an exception, so client future is completed exceptionally with ClassCastException with the cause of initial server side throwable.
Attachments
Attachments
Issue Links
- links to
