diff --git a/src/main/java/net/openhft/chronicle/map/ReplicationHubFindByName.java b/src/main/java/net/openhft/chronicle/map/ReplicationHubFindByName.java index 07f3e0a2d..b0a2625f5 100644 --- a/src/main/java/net/openhft/chronicle/map/ReplicationHubFindByName.java +++ b/src/main/java/net/openhft/chronicle/map/ReplicationHubFindByName.java @@ -71,6 +71,7 @@ class ReplicationHubFindByName implements FindByName { int withChannelId = nextFreeChannel.incrementAndGet(); try (MapKeyContext c = map.context(config.name)) { + c.updateLock().lock(); MapInstanceBuilder value = config.replicatedViaChannel(replicationHub.createChannel(withChannelId)); boolean added = !c.containsKey();