diff --git a/src/main/java/net/openhft/chronicle/map/DiscoveryCluster.java b/src/main/java/net/openhft/chronicle/map/DiscoveryCluster.java index 37bc7f66c..460f33585 100644 --- a/src/main/java/net/openhft/chronicle/map/DiscoveryCluster.java +++ b/src/main/java/net/openhft/chronicle/map/DiscoveryCluster.java @@ -139,11 +139,14 @@ public class DiscoveryCluster { @Override public boolean isIdentifierUnique(byte remoteIdentifier, SocketAddress remoteAddress) { final SocketAddress socketAddress = identifiers.putIfAbsent(remoteIdentifier, remoteAddress); + remoteNodes.activeIdentifierBitSet().set(remoteIdentifier); return socketAddress == null; } }; + remoteNodes.activeIdentifierBitSet().set(identifier); + final TcpReplicationConfig tcpConfig = TcpReplicationConfig .of(tcpPort, toInetSocketArray(knownHostPorts)) .heartBeatInterval(1, SECONDS).nonUniqueIdentifierListener(identifierListener);