diff --git a/src/main/java/net/openhft/chronicle/map/AbstractChannelReplicator.java b/src/main/java/net/openhft/chronicle/map/AbstractChannelReplicator.java index 439706b44..33c6f967d 100644 --- a/src/main/java/net/openhft/chronicle/map/AbstractChannelReplicator.java +++ b/src/main/java/net/openhft/chronicle/map/AbstractChannelReplicator.java @@ -457,11 +457,6 @@ abstract class AbstractChannelReplicator implements Closeable { return entryIn.underlyingObject(); } - @Override - public boolean shouldBeIgnored(final ReplicableEntry entry, final int chronicleId) { - return !externalizable.identifierCheck(entry, chronicleId); - } - @Override public boolean onEntry( ReplicableEntry entry, Bytes payload, int chronicleId, long bootstrapTime) { diff --git a/src/main/java/net/openhft/chronicle/map/Replica.java b/src/main/java/net/openhft/chronicle/map/Replica.java index 9af1fe3c5..55083e4f7 100644 --- a/src/main/java/net/openhft/chronicle/map/Replica.java +++ b/src/main/java/net/openhft/chronicle/map/Replica.java @@ -191,18 +191,6 @@ public interface Replica extends Closeable { */ public void onBeforeEntry() { } - - /** - * its possible that the entry should now be ignored, for example although rare its - * identifier may have recently been changed by another thread, so its no longer applicable - * to send - * - * @param entry the entry you will receive, this does not have to be locked, as - * locking is already provided from the caller. - * @param chronicleId only assigned when clustering - * @return {@code true} if this entry should be ignored - */ - public abstract boolean shouldBeIgnored(final ReplicableEntry entry, final int chronicleId); } }