Skip to content

Commit 2d6db79

Browse files
jfarcandStephane Landelle
authored andcommitted
Improve robusness
1 parent 9b0bf68 commit 2d6db79

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/main/java/com/ning/http/client/providers/netty/NettyAsyncHttpProvider.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2402,7 +2402,8 @@ public void onClose(ChannelHandlerContext ctx, ChannelStateEvent e) {
24022402
NettyWebSocket webSocket = NettyWebSocket.class.cast(h.onCompleted());
24032403
h.resetSuccess();
24042404

2405-
if (!(ctx.getAttachment() instanceof DiscardEvent))
2405+
log.trace("Connection was closed abnormally (that is, with no close frame being sent).");
2406+
if (!(ctx.getAttachment() instanceof DiscardEvent) && webSocket != null)
24062407
webSocket.close(1006, "Connection was closed abnormally (that is, with no close frame being sent).");
24072408
} catch (Throwable t) {
24082409
log.error("onError", t);

0 commit comments

Comments
 (0)