Add logging when websocket outbound error happened

reactor · Oct 3, 2019 · 155ff95 · 155ff95
1 parent 4a08575
commit 155ff95
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git 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
@@ -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());
 		}