diff --git a/src/test/java/net/openhft/chronicle/map/TCPSocketReplicationAfterNodeFailureTest.java b/src/test/java/net/openhft/chronicle/map/TCPSocketReplicationAfterNodeFailureTest.java index 342947c63..3a97331f3 100644 --- a/src/test/java/net/openhft/chronicle/map/TCPSocketReplicationAfterNodeFailureTest.java +++ b/src/test/java/net/openhft/chronicle/map/TCPSocketReplicationAfterNodeFailureTest.java @@ -71,7 +71,7 @@ public class TCPSocketReplicationAfterNodeFailureTest { byte identifier = (byte) 1; TcpTransportAndNetworkConfig tcpConfig = TcpTransportAndNetworkConfig - .of(8021) + .of(8121) .heartBeatInterval(1, TimeUnit.SECONDS); hubOnServer1 = ReplicationHub.builder() @@ -105,7 +105,7 @@ public class TCPSocketReplicationAfterNodeFailureTest { byte identifier = (byte) 2; TcpTransportAndNetworkConfig tcpConfig = TcpTransportAndNetworkConfig - .of(8022, new InetSocketAddress("localhost", 8021)) + .of(8122, new InetSocketAddress("localhost", 8121)) .heartBeatInterval(1, TimeUnit.SECONDS); hubOnServer2 = ReplicationHub.builder() @@ -143,9 +143,9 @@ public class TCPSocketReplicationAfterNodeFailureTest { byte identifier = (byte) 3; TcpTransportAndNetworkConfig tcpConfig = TcpTransportAndNetworkConfig - .of(8023, - new InetSocketAddress("localhost", 8021), - new InetSocketAddress("localhost", 8022)) // this wont be available but just added for completeness + .of(8123, + new InetSocketAddress("localhost", 8121), + new InetSocketAddress("localhost", 8122)) // this wont be available but just added for completeness .heartBeatInterval(1, TimeUnit.SECONDS); hubOnServer3 = ReplicationHub.builder()