Skip to content

Commit

Permalink
remove duplicate reconnect behavior
Browse files Browse the repository at this point in the history
Binding would call `reconnect()` which then gets reconnected on duplexer level just to sent Terminate and hang 😢
  • Loading branch information
quinchs committed Oct 17, 2023
1 parent 6e52959 commit dfb97dd
Showing 1 changed file with 1 addition and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -299,12 +299,7 @@ public final CompletionStage<Void> executeQuery(
@NotNull ExecutionArguments args
) {
logger.debug("Execute request: is connected? {}", getDuplexer().isConnected());
if(!getDuplexer().isConnected()) {
// TODO: check for recursion
return reconnect()
.thenCompose(v -> executeQuery(args));
}


final var hasReleased = new AtomicBoolean();

return CompletableFuture.runAsync(() -> {
Expand Down

0 comments on commit dfb97dd

Please sign in to comment.