org.hornetq.core.server

Class LiveNodeLocator

java.lang.Object

org.hornetq.core.server.LiveNodeLocator

All Implemented Interfaces:

ClusterTopologyListener

Direct Known Subclasses:

AnyLiveNodeLocator, NamedLiveNodeLocator

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

Author:

Andy Taylor

Constructor Summary

Constructors

Constructor and Description
LiveNodeLocator(QuorumManager quorumManager)

Method Summary

Methods

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
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.hornetq.api.core.client.ClusterTopologyListener

nodeDown, nodeUP

Constructor Detail

LiveNodeLocator

public LiveNodeLocator(QuorumManager quorumManager)

Method Detail

locateNode

public abstract void locateNode()
                         throws HornetQException

Locates a possible live server in a cluster

Throws:

HornetQException

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 HornetQException

connects to the cluster

Throws:

HornetQException