Log connection info in StompBrokerRelayMessageHandler

See gh-29287
spring-projects · Nov 23, 2022 · a3c8909 · a3c8909
1 parent e77c426
commit a3c8909
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 3 deletions.
diff --git a/...rc/main/java/org/springframework/messaging/simp/stomp/StompBrokerRelayMessageHandler.java b/...rc/main/java/org/springframework/messaging/simp/stomp/StompBrokerRelayMessageHandler.java
@@ -442,7 +442,7 @@ protected void startInternal() {
 		}
 
 		if (logger.isInfoEnabled()) {
-			logger.info("Starting \"system\" session, " + toString());
+			logger.info("Starting \"system\" session, " + this);
 		}
 
 		StompHeaderAccessor accessor = StompHeaderAccessor.create(StompCommand.CONNECT);
@@ -699,7 +699,7 @@ protected TcpConnection<byte[]> getTcpConnection() {
 		@Override
 		public void afterConnected(TcpConnection<byte[]> connection) {
 			if (logger.isDebugEnabled()) {
-				logger.debug("TCP connection opened in session=" + getSessionId());
+				logger.debug("TCP connection " + connection + " opened in session=" + getSessionId());
 			}
 			this.tcpConnection = connection;
 			connection.onReadInactivity(() -> {
@@ -978,7 +978,7 @@ public void clearConnection() {
 			this.tcpConnection = null;
 			if (conn != null) {
 				if (logger.isDebugEnabled()) {
-					logger.debug("Closing TCP connection in session " + this.sessionId);
+					logger.debug("Closing TCP connection " + conn + " in session " + this.sessionId);
 				}
 				conn.close();
 			}

diff --git a/...g/src/main/java/org/springframework/messaging/tcp/reactor/ReactorNetty2TcpConnection.java b/...g/src/main/java/org/springframework/messaging/tcp/reactor/ReactorNetty2TcpConnection.java
@@ -81,4 +81,8 @@ public void close() {
 		this.completionSink.tryEmitEmpty();
 	}
 
+	@Override
+	public String toString() {
+		return "ReactorNetty2TcpConnection[inbound=" + this.inbound + "]";
+	}
 }
diff --git a/...ng/src/main/java/org/springframework/messaging/tcp/reactor/ReactorNettyTcpConnection.java b/...ng/src/main/java/org/springframework/messaging/tcp/reactor/ReactorNettyTcpConnection.java
@@ -80,4 +80,9 @@ public void close() {
 		this.completionSink.tryEmitEmpty();
 	}
 
+	@Override
+	public String toString() {
+		return "ReactorNettyTcpConnection[inbound=" + this.inbound + "]";
+	}
+
 }