diff --git a/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/AbstractTcpConnection.java b/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/AbstractTcpConnection.java
index 5860a2dc22..e663b7c662 100644
--- a/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/AbstractTcpConnection.java
+++ b/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/AbstractTcpConnection.java
@@ -70,8 +70,6 @@ public abstract class AbstractTcpConnection implements TcpConnection {
 
 	private String hostAddress = "unknown";
 	
-	private int port;
-	
 	private final boolean lookupHost;
 
 	private int hashCode;
@@ -89,7 +87,8 @@ public abstract class AbstractTcpConnection implements TcpConnection {
 				this.hostName = this.hostAddress;
 			}
 		}
-		this.connectionId = this.hostName + ":" + this.port + ":" + this.hashCode;
+		int port = socket.getPort();
+		this.connectionId = this.hostName + ":" + port + ":" + this.hashCode;
 		try {
 			this.soLinger = socket.getSoLinger();
 		} catch (SocketException e) { }