org.hornetq.core.server.impl
public class NamedLiveNodeLocator extends LiveNodeLocator
Configuration.getBackupGroupName()
Constructor and Description |
---|
NamedLiveNodeLocator(String nodeGroupName,
QuorumManager quorumManager) |
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.
|
connectToCluster
public NamedLiveNodeLocator(String nodeGroupName, QuorumManager quorumManager)
public void locateNode() throws HornetQException
LiveNodeLocator
locateNode
in class LiveNodeLocator
HornetQException
public void nodeUP(TopologyMember topologyMember, boolean last)
ClusterTopologyListener
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.public void nodeDown(long eventUID, String nodeID)
ClusterTopologyListener
nodeID
- the id of the node leaving the clusterpublic String getNodeID()
LiveNodeLocator
getNodeID
in class LiveNodeLocator
public Pair<TransportConfiguration,TransportConfiguration> getLiveConfiguration()
LiveNodeLocator
getLiveConfiguration
in class LiveNodeLocator
public void notifyRegistrationFailed(boolean alreadyReplicating)
LiveNodeLocator
notifyRegistrationFailed
in class LiveNodeLocator
Copyright © 2016 JBoss, a division of Red Hat. All Rights Reserved.