Skip to content
This repository was archived by the owner on Jul 21, 2023. It is now read-only.

Commit 567eed7

Browse files
committed
1 parent 0204ca3 commit 567eed7

File tree

2 files changed

+7
-1
lines changed

2 files changed

+7
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2389,7 +2389,7 @@ public void onClose(ChannelHandlerContext ctx, ChannelStateEvent e) {
23892389
WebSocketUpgradeHandler h = WebSocketUpgradeHandler.class.cast(nettyResponse.getAsyncHandler());
23902390
NettyWebSocket webSocket = NettyWebSocket.class.cast(h.onCompleted());
23912391

2392-
webSocket.close();
2392+
webSocket.close(1006, "Connection was closed abnormally (that is, with no close frame being sent).");
23932393
} catch (Throwable t) {
23942394
log.error("onError", t);
23952395
}

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

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -124,6 +124,12 @@ public void close() {
124124
}
125125
}
126126

127+
// @Override
128+
public void close(int statusCode, String reason) {
129+
onClose(statusCode, reason);
130+
listeners.clear();
131+
}
132+
127133
protected void onBinaryFragment(byte[] message, boolean last) {
128134
for (WebSocketListener l : listeners) {
129135
if (WebSocketByteListener.class.isAssignableFrom(l.getClass())) {

0 commit comments

Comments
 (0)