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

Class NamedNodeIdNodeLocator

java.lang.Object

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

org.apache.activemq.artemis.core.server.impl.NamedNodeIdNodeLocator

All Implemented Interfaces:

ClusterTopologyListener

public class NamedNodeIdNodeLocator
extends NodeLocator

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.activemq.artemis.core.server.NodeLocator

NodeLocator.BackupRegistrationListener

Constructor Summary

Constructors

Constructor	Description
NamedNodeIdNodeLocator(String nodeID, Pair<TransportConfiguration,TransportConfiguration> configuration)

Method Summary

Modifier and Type	Method	Description
String	getNodeID()	Returns the node id for the current connector.
Pair<TransportConfiguration,TransportConfiguration>	getPrimaryConfiguration()	Returns the current connector.
void	locateNode()	Locates a server in a cluster
void	locateNode(long timeout)	Locates a server in a cluster with a timeout
void	nodeDown(long eventUID, String nodeID)	Triggered when a node leaves the cluster.
void	nodeUP(TopologyMember member, boolean last)	Triggered when a node joins the cluster.

Methods inherited from class org.apache.activemq.artemis.core.server.NodeLocator

connectToCluster, notifyRegistrationFailed

Methods inherited from class java.lang.Object

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

Constructor Details

NamedNodeIdNodeLocator

public NamedNodeIdNodeLocator(String nodeID,
 Pair<TransportConfiguration,TransportConfiguration> configuration)

Method Details

locateNode

public void locateNode(long timeout)
                throws ActiveMQException

Description copied from class: NodeLocator

Locates a server in a cluster with a timeout

Specified by:

locateNode in class NodeLocator

Throws:

ActiveMQException

locateNode

public void locateNode()
                throws ActiveMQException

Description copied from class: NodeLocator

Locates a server in a cluster

Specified by:

locateNode in class NodeLocator

Throws:

ActiveMQException

getPrimaryConfiguration

public Pair<TransportConfiguration,TransportConfiguration> getPrimaryConfiguration()

Description copied from class: NodeLocator

Returns the current connector.

Specified by:

getPrimaryConfiguration in class NodeLocator

Returns:

the current connector

getNodeID

public String getNodeID()

Description copied from class: NodeLocator

Returns the node id for the current connector.

Specified by:

getNodeID in class NodeLocator

Returns:

the node id for the current connector

nodeUP

public void nodeUP(TopologyMember member,
 boolean last)

Description copied from interface: ClusterTopologyListener

Triggered when a node joins the cluster.

last - if the whole cluster topology is being transmitted (after adding the listener to the cluster connection) this parameter will be true for the last topology member.

nodeDown

public void nodeDown(long eventUID,
 String nodeID)

Description copied from interface: ClusterTopologyListener

Triggered when a node leaves the cluster.

nodeID - the id of the node leaving the cluster