File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed
src/main/java/com/ning/http/client/providers/netty Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -67,16 +67,18 @@ public final void operationComplete(ChannelFuture f) throws Exception {
67
67
} else {
68
68
Throwable cause = f .getCause ();
69
69
70
+ logger .debug ("Trying to recover a dead cached channel {} with a retry value of {} " , f .getChannel (), future .canRetry ());
70
71
if (future .canRetry () && cause != null && (NettyAsyncHttpProvider .abortOnDisconnectException (cause )
71
72
|| ClosedChannelException .class .isAssignableFrom (cause .getClass ())
72
73
|| future .getState () != NettyResponseFuture .STATE .NEW )) {
73
-
74
+
75
+ logger .debug ("Retrying {} " , nettyRequest );
74
76
if (future .provider ().remotelyClosed (f .getChannel (), future )) {
75
77
return ;
76
78
}
77
79
}
78
80
79
- logger .warn ("Connect exception: {}" , cause );
81
+ logger .warn ("Failed to recover from exception: {} with channel {} " , cause , f . getChannel () );
80
82
81
83
ConnectException e = new ConnectException (f .getCause () != null ? cause .getMessage () : future .getURI ().toString ());
82
84
if (cause != null ) {
You can’t perform that action at this time.
0 commit comments