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();
     }