HCOLL-134 ( release draft cut of the code so that I can test it across my network )

This commit is contained in:
Rob Austin
2014-10-01 19:20:49 +01:00
parent 8506d52490
commit c11a0cceac
@@ -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);