From c9365e523886d554c857c53761c8993e4d7cc6cd Mon Sep 17 00:00:00 2001
From: rob <rob.austin@boundedbuffer.com>
Date: Wed, 14 Oct 2015 10:46:58 +0100
Subject: [PATCH] HCOLL-403 removed another filter that was preventing all the
 message to be sent ( from all the nodes on bootstrap )

---
 .../openhft/chronicle/map/ReplicatedChronicleMap.java    | 4 ----
 .../map/TCPSocketReplicationAfterNodeFailure.java        | 9 +++++++--
 2 files changed, 7 insertions(+), 6 deletions(-)

diff --git a/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java b/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java
index 4df854dbb..6d71a5776 100644
--- a/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java
+++ b/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java
@@ -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;
diff --git a/src/test/java/net/openhft/chronicle/map/TCPSocketReplicationAfterNodeFailure.java b/src/test/java/net/openhft/chronicle/map/TCPSocketReplicationAfterNodeFailure.java
index 25c2dea92..0d64b1c86 100644
--- a/src/test/java/net/openhft/chronicle/map/TCPSocketReplicationAfterNodeFailure.java
+++ b/src/test/java/net/openhft/chronicle/map/TCPSocketReplicationAfterNodeFailure.java
@@ -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();
     }