Package org.apache.activemq.artemis.core.server

Class NodeLocator

java.lang.Object

org.apache.activemq.artemis.core.server.NodeLocator

All Implemented Interfaces:

ClusterTopologyListener

Direct Known Subclasses:

AnyNodeLocatorForReplication, AnyNodeLocatorForScaleDown, NamedNodeIdLocatorForReplication, NamedNodeIdNodeLocator, NamedNodeLocatorForReplication, NamedNodeLocatorForScaleDown

public abstract class NodeLocator
extends Object
implements ClusterTopologyListener

A class that will locate a particular server running in a cluster. How this server 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).

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	NodeLocator.BackupRegistrationListener

Constructor Summary

Constructors

Constructor	Description
NodeLocator()	Use this constructor when the NodeLocator is used for scaling down rather than replicating
NodeLocator(NodeLocator.BackupRegistrationListener backupRegistrationListener)

Method Summary

Modifier and Type	Method	Description
void	connectToCluster(ServerLocatorInternal serverLocator)	connects to the cluster
abstract String	getNodeID()	Returns the node id for the current connector.
abstract Pair<TransportConfiguration,TransportConfiguration>	getPrimaryConfiguration()	Returns the current connector.
abstract void	locateNode()	Locates a server in a cluster
abstract void	locateNode(long timeout)	Locates a server in a cluster with a timeout
void	notifyRegistrationFailed(boolean alreadyReplicating)	tells the locator 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 Details

NodeLocator

public NodeLocator(NodeLocator.BackupRegistrationListener backupRegistrationListener)

NodeLocator

public NodeLocator()

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

Method Details

locateNode

public abstract void locateNode(long timeout)
                         throws ActiveMQException

Locates a server in a cluster with a timeout

Throws:

ActiveMQException

locateNode

public abstract void locateNode()
                         throws ActiveMQException

Locates a server in a cluster

Throws:

ActiveMQException

getPrimaryConfiguration

public abstract Pair<TransportConfiguration,TransportConfiguration> getPrimaryConfiguration()

Returns the current connector.

Returns:

the current connector

getNodeID

public abstract String getNodeID()

Returns the node id for the current connector.

Returns:

the node id for the current connector

notifyRegistrationFailed

public void notifyRegistrationFailed(boolean alreadyReplicating)

tells the locator the current connector has failed.

connectToCluster

public void connectToCluster(ServerLocatorInternal serverLocator)
                      throws ActiveMQException

connects to the cluster

Throws:

ActiveMQException