changed ports

This commit is contained in:
rob
2015-12-03 04:41:02 +03:00
committed by leventov
parent c0b8846b20
commit b34c4a2faa
@@ -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()