Skip to content

Commit ac65fe7

Browse files
author
Stephane Landelle
committed
Fix class names
1 parent 282a6e8 commit ac65fe7

File tree

3 files changed

+8
-3
lines changed

3 files changed

+8
-3
lines changed

providers/netty-commons/src/main/java/org/asynchttpclient/providers/netty/commons/future/StackTraceInspector.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,11 +30,16 @@ private static boolean abortOnConnectCloseException(Throwable t) {
3030
|| (t.getCause() != null && abortOnConnectCloseException(t.getCause()));
3131
}
3232

33-
public static boolean abortOnDisconnectException(Throwable t) {
33+
public static boolean abortOnNetty3DisconnectException(Throwable t) {
3434
return exceptionInMethod(t, "io.netty.handler.ssl.SslHandler", "disconnect")
3535
|| (t.getCause() != null && abortOnConnectCloseException(t.getCause()));
3636
}
3737

38+
public static boolean abortOnNetty4DisconnectException(Throwable t) {
39+
return exceptionInMethod(t, "io.netty.handler.ssl.SslHandler", "disconnect")
40+
|| (t.getCause() != null && abortOnConnectCloseException(t.getCause()));
41+
}
42+
3843
public static boolean abortOnReadOrWriteException(Throwable t) {
3944

4045
try {

providers/netty3/src/main/java/org/asynchttpclient/providers/netty3/request/NettyConnectListener.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -133,7 +133,7 @@ private void onFutureFailure(Channel channel, Throwable cause) {
133133
LOGGER.debug("Trying to recover from failing to connect channel {} with a retry value of {} ", channel, canRetry);
134134
if (canRetry
135135
&& cause != null
136-
&& (cause instanceof ClosedChannelException || future.getState() != NettyResponseFuture.STATE.NEW || StackTraceInspector.abortOnDisconnectException(cause))) {
136+
&& (cause instanceof ClosedChannelException || future.getState() != NettyResponseFuture.STATE.NEW || StackTraceInspector.abortOnNetty3DisconnectException(cause))) {
137137

138138
if (!requestSender.retry(future))
139139
return;

providers/netty4/src/main/java/org/asynchttpclient/providers/netty4/request/NettyConnectListener.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -131,7 +131,7 @@ private void onFutureFailure(Channel channel, Throwable cause) {
131131
LOGGER.debug("Trying to recover from failing to connect channel {} with a retry value of {} ", channel, canRetry);
132132
if (canRetry//
133133
&& cause != null//
134-
&& (cause instanceof ClosedChannelException || future.getState() != NettyResponseFuture.STATE.NEW || StackTraceInspector.abortOnDisconnectException(cause))) {
134+
&& (cause instanceof ClosedChannelException || future.getState() != NettyResponseFuture.STATE.NEW || StackTraceInspector.abortOnNetty4DisconnectException(cause))) {
135135

136136
if (requestSender.retry(future)) {
137137
return;

0 commit comments

Comments
 (0)