Skip to content

Commit 3972f9c

Browse files
committed
Hot fix: Add missing return after processing in ExecutionResultHandler
- Without the return, an exception was thrown always
1 parent 3af98b4 commit 3972f9c

File tree

1 file changed

+2
-0
lines changed
  • playground-service-adapters/playground-service-kafka-commands-senders/src/main/java/ar/edu/itba/cep/playground_service/commands/executor_service

1 file changed

+2
-0
lines changed

playground-service-adapters/playground-service-kafka-commands-senders/src/main/java/ar/edu/itba/cep/playground_service/commands/executor_service/ExecutionResultHandler.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -62,6 +62,7 @@ protected void andThen(final ExecutionResultDto executionResultDto, final Messag
6262
private void processResultType(final long requestId, final ExecutionResultDto executionResultDto) {
6363
if (executionResultDto instanceof TimedOutExecutionResultDto) {
6464
executionResultProcessor.receiveTimedOut(requestId);
65+
return;
6566
}
6667
if (executionResultDto instanceof FinishedExecutionResultDto) {
6768
final var finishedExecutionResultDto = (FinishedExecutionResultDto) executionResultDto;
@@ -71,6 +72,7 @@ private void processResultType(final long requestId, final ExecutionResultDto ex
7172
finishedExecutionResultDto.getStderr(),
7273
requestId
7374
);
75+
return;
7476
}
7577
throw new IllegalArgumentException("Unknown subtype");
7678
}

0 commit comments

Comments
 (0)