org.apache.activemq.artemis.core.server

Class LiveNodeLocator

java.lang.Object

org.apache.activemq.artemis.core.server.LiveNodeLocator

All Implemented Interfaces:

ClusterTopologyListener

Direct Known Subclasses:

AnyLiveNodeLocatorForReplication, AnyLiveNodeLocatorForScaleDown, NamedLiveNodeLocatorForReplication, NamedLiveNodeLocatorForScaleDown, NamedNodeIdNodeLocator

public abstract class LiveNodeLocator
extends Object
implements ClusterTopologyListener

A class that will locate a particular live server running in a cluster. How this live is chosen is a job for the implementation. This is used for replication (which needs a QuorumManager) and scaling-down (which does not need a QuorumManager).

Constructor Summary

Constructors

Constructor and Description
LiveNodeLocator() Use this constructor when the LiveNodeLocator is used for scaling down rather than replicating
LiveNodeLocator(SharedNothingBackupQuorum backupQuorum)

Method Summary

Modifier and Type	Method and Description
void	connectToCluster(ServerLocatorInternal serverLocator) connects to the cluster
abstract Pair<TransportConfiguration,TransportConfiguration>	getLiveConfiguration() Returns the current connector
abstract String	getNodeID() Returns the node id for the current connector
abstract void	locateNode() Locates a possible live server in a cluster
abstract void	locateNode(long timeout) Locates a possible live server in a cluster with a timeout
void	notifyRegistrationFailed(boolean alreadyReplicating) tells the locator the the current connector has failed.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.activemq.artemis.api.core.client.ClusterTopologyListener

nodeDown, nodeUP

Constructor Detail

LiveNodeLocator

public LiveNodeLocator(SharedNothingBackupQuorum backupQuorum)

LiveNodeLocator

public LiveNodeLocator()

Use this constructor when the LiveNodeLocator is used for scaling down rather than replicating

Method Detail

locateNode

public abstract void locateNode(long timeout)
                         throws ActiveMQException

Locates a possible live server in a cluster with a timeout

Throws:

ActiveMQException

locateNode

public abstract void locateNode()
                         throws ActiveMQException

Locates a possible live server in a cluster

Throws:

ActiveMQException

getLiveConfiguration

public abstract Pair<TransportConfiguration,TransportConfiguration> getLiveConfiguration()

Returns the current connector

getNodeID

public abstract String getNodeID()

Returns the node id for the current connector

notifyRegistrationFailed

public void notifyRegistrationFailed(boolean alreadyReplicating)

tells the locator the the current connector has failed.

connectToCluster

public void connectToCluster(ServerLocatorInternal serverLocator)
                      throws ActiveMQException

connects to the cluster

Throws:

ActiveMQException