HCOLL-403 removed another filter that was preventing all the message to be sent ( from all the nodes on bootstrap )

This commit is contained in:
rob
2015-12-03 04:38:43 +03:00
committed by leventov
parent 36ac265115
commit c9365e5238
2 changed files with 7 additions and 6 deletions
@@ -412,10 +412,6 @@ public class ReplicatedChronicleMap<K, V, R> extends VanillaChronicleMap<K, V, R
final long timeStamp = entry.readLong();
final byte identifier = entry.readByte();
if (identifier != identifier()) {
// although unlikely, this may occur if the entry has been updated
return;
}
final boolean isDeleted = entry.readBoolean();
long valueSize;
@@ -105,7 +105,8 @@ public class TCPSocketReplicationAfterNodeFailure {
byte identifier = (byte) 2;
TcpTransportAndNetworkConfig tcpConfig = TcpTransportAndNetworkConfig
.of(8022, new InetSocketAddress("localhost", 8021)).heartBeatInterval(1, TimeUnit.SECONDS);
.of(8022, new InetSocketAddress("localhost", 8021))
.heartBeatInterval(1, TimeUnit.SECONDS);
hubOnServer2 = ReplicationHub.builder()
.tcpTransportAndNetwork(tcpConfig)
@@ -142,7 +143,10 @@ public class TCPSocketReplicationAfterNodeFailure {
byte identifier = (byte) 3;
TcpTransportAndNetworkConfig tcpConfig = TcpTransportAndNetworkConfig
.of(8023, new InetSocketAddress("localhost", 8021)).heartBeatInterval(1, TimeUnit.SECONDS);
.of(8023,
new InetSocketAddress("localhost", 8021),
new InetSocketAddress("localhost", 8022)) // this wont be available but just added for completeness
.heartBeatInterval(1, TimeUnit.SECONDS);
hubOnServer3 = ReplicationHub.builder()
.tcpTransportAndNetwork(tcpConfig)
@@ -165,6 +169,7 @@ public class TCPSocketReplicationAfterNodeFailure {
assertEquals(3, favoriteComputerServer1.size());
favoriteComputerServer1.close();
favoriteComputerServer3.close();
}