public class AnyLiveNodeLocatorForScaleDown extends LiveNodeLocator
Constructor and Description |
---|
AnyLiveNodeLocatorForScaleDown(ActiveMQServerImpl 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 |
locateNode(long timeout)
Locates a possible live server in a cluster with a timeout
|
void |
nodeDown(long eventUID,
String nodeID) |
void |
nodeUP(TopologyMember topologyMember,
boolean last) |
void |
notifyRegistrationFailed(boolean alreadyReplicating)
tells the locator the the current connector has failed.
|
connectToCluster
public AnyLiveNodeLocatorForScaleDown(ActiveMQServerImpl server)
public void locateNode() throws ActiveMQException
LiveNodeLocator
locateNode
in class LiveNodeLocator
ActiveMQException
public void locateNode(long timeout) throws ActiveMQException
LiveNodeLocator
locateNode
in class LiveNodeLocator
ActiveMQException
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 © 2018 The Apache Software Foundation. All Rights Reserved.