diff --git a/src/main/java/net/openhft/chronicle/map/Replica.java b/src/main/java/net/openhft/chronicle/map/Replica.java index ec6e9f170..ee7888220 100644 --- a/src/main/java/net/openhft/chronicle/map/Replica.java +++ b/src/main/java/net/openhft/chronicle/map/Replica.java @@ -189,6 +189,7 @@ public interface Replica extends Closeable { * operation and add zeroBytes, if the identifier in the entry did not * match the maps local * @param chronicleId is the channel id used to identify the canonical map or queue + * @param keys list of keys corresponding to given ReplicableEntry (added to during the call) */ void writeExternalEntry(ReplicableEntry entry, Bytes payload, @NotNull Bytes destination, int chronicleId, ArrayList keys ); diff --git a/src/test/java/net/openhft/chronicle/map/BasicReplicationTest.java b/src/test/java/net/openhft/chronicle/map/BasicReplicationTest.java index 38a0f48c0..9dc28723b 100644 --- a/src/test/java/net/openhft/chronicle/map/BasicReplicationTest.java +++ b/src/test/java/net/openhft/chronicle/map/BasicReplicationTest.java @@ -177,6 +177,7 @@ public class BasicReplicationTest { private final Bytes buffer = Bytes.elasticByteBuffer(4096); private final ExecutorService delayedExecutor = Executors.newSingleThreadExecutor(); private final AtomicInteger messagesInflight = new AtomicInteger(0); + private final ArrayList keys = new ArrayList<>(); IteratorAndDestinationMap(final ReplicatedChronicleMap.ModificationIterator modificationIterator, final ReplicatedChronicleMap sourceMap, @@ -190,7 +191,8 @@ public class BasicReplicationTest { public void onEntry(final ReplicableEntry entry, final int chronicleId) { try { buffer.clear(); - sourceMap.writeExternalEntry(entry, null, buffer, chronicleId); + keys.clear(); + sourceMap.writeExternalEntry(entry, null, buffer, chronicleId,keys); buffer.readPosition(0); buffer.readLimit(buffer.writePosition()); @@ -221,4 +223,4 @@ public class BasicReplicationTest { destinationMap.setRemoteNodeCouldBootstrapFrom((byte) chronicleId, bootstrapTime); } } -} \ No newline at end of file +}