From f0bcd784b73bc01a77923fb97349ea7087479dac Mon Sep 17 00:00:00 2001 From: leventov Date: Thu, 17 Dec 2015 21:25:09 +0300 Subject: [PATCH] Remove EntryCallback.shouldBeIgnored() --- .../chronicle/map/AbstractChannelReplicator.java | 5 ----- src/main/java/net/openhft/chronicle/map/Replica.java | 12 ------------ 2 files changed, 17 deletions(-) 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); } }