com.hazelcast.cluster

Class AbstractJoiner

java.lang.Object

com.hazelcast.cluster.AbstractJoiner

All Implemented Interfaces:

Joiner

Direct Known Subclasses:

MulticastJoiner, TcpIpJoiner

public abstract class AbstractJoiner
extends Object
implements Joiner

Field Summary

Fields

Modifier and Type	Field and Description
protected Set<Address>	blacklistedAddresses
protected Config	config
protected ILogger	logger
protected Node	node

Constructor Summary

Constructors

Constructor and Description
AbstractJoiner(Node node)

Method Summary

Methods

Modifier and Type	Method and Description
void	blacklist(Address callerAddress) Adds an address to the blacklist.
abstract void	doJoin()
protected long	getMaxJoinMillis()
protected long	getMaxJoinTimeToMasterNode()
long	getStartTime()
Address	getTargetAddress()
boolean	isBlacklisted(Address address) Checks if an address is blacklisted.
void	join()
void	reset()
void	setTargetAddress(Address targetAddress)
protected void	startClusterMerge(Address targetAddress)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.cluster.Joiner

getType, searchForOtherClusters

Field Detail

blacklistedAddresses

protected final Set<Address> blacklistedAddresses

config

protected final Config config

node

protected final Node node

logger

protected final ILogger logger

Constructor Detail

AbstractJoiner

public AbstractJoiner(Node node)

Method Detail

blacklist

public void blacklist(Address callerAddress)

Description copied from interface: Joiner

Adds an address to the blacklist. Blacklist is useful if a node should ignore another node, e.g. when the groupname of 2 machines is not the same and they should form different clusters. Method is thread-safe. If the address already is blacklisted, the call is ignored

Specified by:

blacklist in interface Joiner

Parameters:

callerAddress - the address to blacklist.

See Also:

Joiner.isBlacklisted(com.hazelcast.nio.Address)

isBlacklisted

public boolean isBlacklisted(Address address)

Description copied from interface: Joiner

Checks if an address is blacklisted. Method is thread-safe.

Specified by:

isBlacklisted in interface Joiner

Parameters:

address - the address to check.

Returns:

true if blacklisted, false otherwise.

See Also:

Joiner.blacklist(com.hazelcast.nio.Address)

doJoin

public abstract void doJoin()

join

public final void join()

Specified by:

join in interface Joiner

getMaxJoinMillis

protected final long getMaxJoinMillis()

getMaxJoinTimeToMasterNode

protected final long getMaxJoinTimeToMasterNode()

reset

public void reset()

Specified by:

reset in interface Joiner

startClusterMerge

protected void startClusterMerge(Address targetAddress)

getStartTime

public final long getStartTime()

Specified by:

getStartTime in interface Joiner

setTargetAddress

public void setTargetAddress(Address targetAddress)

Specified by:

setTargetAddress in interface Joiner

getTargetAddress

public Address getTargetAddress()