Skip to content

Commit 7035a13

Browse files
committed
NettyChannelConnector doesn't properly report RejectedExecutionException, close AsyncHttpClient#1385
1 parent cb63be5 commit 7035a13

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

client/src/main/java/org/asynchttpclient/netty/request/NettyChannelConnector.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -73,9 +73,9 @@ public void connect(final Bootstrap bootstrap, final NettyConnectListener<?> con
7373
connect0(bootstrap, connectListener, remoteAddress);
7474
} catch (RejectedExecutionException e) {
7575
if (clientState.isClosed()) {
76-
connectListener.onFailure(null, e);
77-
} else {
7876
LOGGER.info("Connect crash but engine is shutting down");
77+
} else {
78+
connectListener.onFailure(null, e);
7979
}
8080
}
8181
}

0 commit comments

Comments
 (0)