diff --git a/src/main/java/reactor/netty/http/client/WebsocketClientOperations.java b/src/main/java/reactor/netty/http/client/WebsocketClientOperations.java index 0729dd247c..20b14be8d8 100644 --- a/src/main/java/reactor/netty/http/client/WebsocketClientOperations.java +++ b/src/main/java/reactor/netty/http/client/WebsocketClientOperations.java @@ -166,6 +166,9 @@ protected void onOutboundComplete() { @Override protected void onOutboundError(Throwable err) { if (channel().isActive()) { + if (log.isDebugEnabled()) { + log.debug(format(channel(), "Outbound error happened"), err); + } sendCloseNow(new CloseWebSocketFrame(1002, "Client internal error")); } } diff --git a/src/main/java/reactor/netty/http/server/WebsocketServerOperations.java b/src/main/java/reactor/netty/http/server/WebsocketServerOperations.java index 839a63a286..de5546aab4 100644 --- a/src/main/java/reactor/netty/http/server/WebsocketServerOperations.java +++ b/src/main/java/reactor/netty/http/server/WebsocketServerOperations.java @@ -156,6 +156,9 @@ protected void onOutboundComplete() { @Override protected void onOutboundError(Throwable err) { if (channel().isActive()) { + if (log.isDebugEnabled()) { + log.debug(format(channel(), "Outbound error happened"), err); + } sendCloseNow(new CloseWebSocketFrame(1002, "Server internal error"), f -> terminate()); }