diff --git a/src/main/java/net/openhft/chronicle/map/impl/stage/input/ReplicatedInput.java b/src/main/java/net/openhft/chronicle/map/impl/stage/input/ReplicatedInput.java index 6ac780ea2..00d75bc82 100644 --- a/src/main/java/net/openhft/chronicle/map/impl/stage/input/ReplicatedInput.java +++ b/src/main/java/net/openhft/chronicle/map/impl/stage/input/ReplicatedInput.java @@ -91,10 +91,6 @@ public abstract class ReplicatedInput } public void processReplicatedEvent() { - if (riId == mh.m().identifier()) { - // this may occur when working with UDP, as we may receive our own data - return; - } mh.m().setLastModificationTime(riId, bootstrapTimestamp);