diff --git a/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java b/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java index 537eb4b59..dc7bd211e 100644 --- a/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java +++ b/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java @@ -829,7 +829,7 @@ final class ReplicatedChronicleMap, BytesReader keyReader = null; if (hasAttachedEventListeners()) { - ThreadLocalCopies keyCopies = keyInteropProvider.getCopies(null); + ThreadLocalCopies keyCopies = keyReaderProvider.getCopies(null); keyReader = keyReaderProvider.get(keyCopies, originalKeyReader); ThreadLocalCopies valueCopies = valueReaderProvider.getCopies(keyCopies);