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

Class NamedNodeIdNodeLocator

java.lang.Object

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

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

All Implemented Interfaces:

org.apache.activemq.artemis.api.core.client.ClusterTopologyListener

public class NamedNodeIdNodeLocator
extends LiveNodeLocator

Constructor Summary

Constructors

Constructor and Description
NamedNodeIdNodeLocator(String nodeID, org.apache.activemq.artemis.api.core.Pair<org.apache.activemq.artemis.api.core.TransportConfiguration,org.apache.activemq.artemis.api.core.TransportConfiguration> liveConfiguration)

Method Summary

Modifier and Type	Method and Description
org.apache.activemq.artemis.api.core.Pair<org.apache.activemq.artemis.api.core.TransportConfiguration,org.apache.activemq.artemis.api.core.TransportConfiguration>	getLiveConfiguration() Returns the current connector
String	getNodeID() Returns the node id for the current connector
void	locateNode() Locates a possible live server in a cluster
void	locateNode(long timeout) Locates a possible live server in a cluster with a timeout
void	nodeDown(long eventUID, String nodeID)
void	nodeUP(org.apache.activemq.artemis.api.core.client.TopologyMember member, boolean last)

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

connectToCluster, notifyRegistrationFailed

Methods inherited from class java.lang.Object

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

Constructor Detail

NamedNodeIdNodeLocator

public NamedNodeIdNodeLocator(String nodeID,
                              org.apache.activemq.artemis.api.core.Pair<org.apache.activemq.artemis.api.core.TransportConfiguration,org.apache.activemq.artemis.api.core.TransportConfiguration> liveConfiguration)

Method Detail

locateNode

public void locateNode(long timeout)
                throws org.apache.activemq.artemis.api.core.ActiveMQException

Description copied from class: LiveNodeLocator

Locates a possible live server in a cluster with a timeout

Specified by:

locateNode in class LiveNodeLocator

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException

locateNode

public void locateNode()
                throws org.apache.activemq.artemis.api.core.ActiveMQException

Description copied from class: LiveNodeLocator

Locates a possible live server in a cluster

Specified by:

locateNode in class LiveNodeLocator

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException

getLiveConfiguration

public org.apache.activemq.artemis.api.core.Pair<org.apache.activemq.artemis.api.core.TransportConfiguration,org.apache.activemq.artemis.api.core.TransportConfiguration> getLiveConfiguration()

Description copied from class: LiveNodeLocator

Returns the current connector

Specified by:

getLiveConfiguration in class LiveNodeLocator

getNodeID

public String getNodeID()

Description copied from class: LiveNodeLocator

Returns the node id for the current connector

Specified by:

getNodeID in class LiveNodeLocator

nodeUP

public void nodeUP(org.apache.activemq.artemis.api.core.client.TopologyMember member,
                   boolean last)

nodeDown

public void nodeDown(long eventUID,
                     String nodeID)