com.hazelcast.cluster.impl

Class TcpIpJoiner

java.lang.Object

com.hazelcast.internal.cluster.impl.AbstractJoiner

com.hazelcast.cluster.impl.TcpIpJoiner

All Implemented Interfaces:

Joiner

Direct Known Subclasses:

DiscoveryJoiner

public class TcpIpJoiner
extends AbstractJoiner

Field Summary

Fields inherited from class com.hazelcast.internal.cluster.impl.AbstractJoiner

blacklistedAddresses, clusterJoinManager, clusterService, config, logger, node

Constructor Summary

Constructors

Constructor and Description
TcpIpJoiner(Node node)

Method Summary

Modifier and Type	Method and Description
void	doJoin()
static Collection<String>	getConfigurationMembers(Config config)
static Collection<String>	getConfigurationMembers(TcpIpConfig tcpIpConfig)
ConcurrentMap<Address,Long>	getKnownMemberAddresses()
protected Collection<String>	getMembers()
protected Collection<Address>	getPossibleAddresses()
protected Collection<Address>	getPossibleAddressesForInitialJoin()
String	getType()
boolean	isClaimingMastership()
void	onMemberAdded(Member member)
void	onMemberRemoved(Member member)
void	searchForOtherClusters()

Methods inherited from class com.hazelcast.internal.cluster.impl.AbstractJoiner

blacklist, getMaxJoinMillis, getMaxJoinTimeToMasterNode, getStartTime, getTargetAddress, isBlacklisted, join, reset, sendSplitBrainJoinMessageAndCheckResponse, setTargetAddress, shouldRetry, startClusterMerge, unblacklist

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TcpIpJoiner

public TcpIpJoiner(Node node)

Method Detail

isClaimingMastership

public boolean isClaimingMastership()

doJoin

public void doJoin()

Specified by:

doJoin in class AbstractJoiner

getPossibleAddressesForInitialJoin

protected Collection<Address> getPossibleAddressesForInitialJoin()

getPossibleAddresses

protected Collection<Address> getPossibleAddresses()

getMembers

protected Collection<String> getMembers()

getConfigurationMembers

public static Collection<String> getConfigurationMembers(Config config)

getConfigurationMembers

public static Collection<String> getConfigurationMembers(TcpIpConfig tcpIpConfig)

onMemberAdded

public void onMemberAdded(Member member)

onMemberRemoved

public void onMemberRemoved(Member member)

searchForOtherClusters

public void searchForOtherClusters()

getKnownMemberAddresses

public ConcurrentMap<Address,Long> getKnownMemberAddresses()

getType

public String getType()