mirror of
https://github.com/OpenHFT/Chronicle-Map.git
synced 2021-09-13 01:26:12 +00:00
Remove EntryCallback.shouldBeIgnored()
This commit is contained in:
@@ -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) {
|
||||
|
||||
@@ -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);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user