public class AnyLiveNodeLocator extends LiveNodeLocator
Constructor and Description |
---|
AnyLiveNodeLocator(QuorumManager quorumManager,
HornetQServerImpl server) |
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)
if a node goes down we try all the connectors again as one may now be available for
replication
TODO: there will be a better way to do this by finding which nodes backup has gone down.
|
void |
nodeUP(TopologyMember topologyMember,
boolean last) |
void |
notifyRegistrationFailed(boolean alreadyReplicating)
tells the locator the the current connector has failed.
|
connectToCluster
public AnyLiveNodeLocator(QuorumManager quorumManager, HornetQServerImpl server)
public void locateNode() throws HornetQException
LiveNodeLocator
locateNode
in class LiveNodeLocator
HornetQException
public void nodeUP(TopologyMember topologyMember, boolean last)
public void nodeDown(long eventUID, String nodeID)
public 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 © 2017 JBoss, a division of Red Hat. All Rights Reserved.