org.hornetq.core.server.impl

Class NamedLiveNodeLocator

java.lang.Object

org.hornetq.core.server.LiveNodeLocator

org.hornetq.core.server.impl.NamedLiveNodeLocator

All Implemented Interfaces:

ClusterTopologyListener

public class NamedLiveNodeLocator
extends LiveNodeLocator

NamedLiveNodeLocator looks for a live server in the cluster with a specific nodeGroupName

Author:

Andy Taylor

See Also:

Configuration.getBackupGroupName()

Constructor Summary

Constructors

Constructor and Description
NamedLiveNodeLocator(String nodeGroupName, QuorumManager quorumManager)

Method Summary

Methods

Modifier and Type	Method and Description
Pair<TransportConfiguration,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	nodeDown(long eventUID, String nodeID) Triggered when a node leaves the cluster.
void	nodeUP(TopologyMember topologyMember, boolean last) Triggered when a node joins the cluster.
void	notifyRegistrationFailed(boolean alreadyReplicating) tells the locator the the current connector has failed.

Methods inherited from class org.hornetq.core.server.LiveNodeLocator

connectToCluster

Methods inherited from class java.lang.Object

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

Constructor Detail

NamedLiveNodeLocator

public NamedLiveNodeLocator(String nodeGroupName,
                    QuorumManager quorumManager)

Method Detail

locateNode

public void locateNode()
                throws HornetQException

Description copied from class: LiveNodeLocator

Locates a possible live server in a cluster

Specified by:

locateNode in class LiveNodeLocator

Throws:

HornetQException

nodeUP

public void nodeUP(TopologyMember topologyMember,
          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

getNodeID

public String getNodeID()

Description copied from class: LiveNodeLocator

Returns the node id for the current connector

Specified by:

getNodeID in class LiveNodeLocator

getLiveConfiguration

public Pair<TransportConfiguration,TransportConfiguration> getLiveConfiguration()

Description copied from class: LiveNodeLocator

Returns the current connector

Specified by:

getLiveConfiguration in class LiveNodeLocator

notifyRegistrationFailed

public void notifyRegistrationFailed(boolean alreadyReplicating)

Description copied from class: LiveNodeLocator

tells the locator the the current connector has failed.

Overrides:

notifyRegistrationFailed in class LiveNodeLocator