public interface ClusterConnection extends ActiveMQComponent, ClusterTopologyListener
Modifier and Type | Method and Description |
---|---|
void |
addClusterTopologyListener(ClusterTopologyListener listener) |
String |
describe() |
void |
disconnectRecord(String targetNodeID) |
void |
flushExecutor() |
long |
getCallTimeout() |
TransportConfiguration |
getConnector() |
SimpleString |
getName() |
String |
getNodeID() |
Map<String,String> |
getNodes()
Only used for tests?
|
ActiveMQServer |
getServer() |
Topology |
getTopology() |
void |
informClusterOfBackup() |
boolean |
isNodeActive(String id) |
void |
nodeAnnounced(long eventUID,
String nodeID,
String backupGroupName,
String scaleDownGroupName,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean backup) |
void |
removeClusterTopologyListener(ClusterTopologyListener listener) |
void |
removeRecord(String targetNodeID) |
boolean |
verify(String clusterUser,
String clusterPassword)
Verifies whether user and password match the ones configured for this ClusterConnection.
|
isStarted, start, stop
nodeDown, nodeUP
SimpleString getName()
String getNodeID()
ActiveMQServer getServer()
void nodeAnnounced(long eventUID, String nodeID, String backupGroupName, String scaleDownGroupName, Pair<TransportConfiguration,TransportConfiguration> connectorPair, boolean backup)
void addClusterTopologyListener(ClusterTopologyListener listener)
void removeClusterTopologyListener(ClusterTopologyListener listener)
TransportConfiguration getConnector()
Topology getTopology()
void flushExecutor()
String describe()
void informClusterOfBackup()
boolean isNodeActive(String id)
boolean verify(String clusterUser, String clusterPassword)
clusterUser
- clusterPassword
- true
if username and password match, false
otherwise.void removeRecord(String targetNodeID)
void disconnectRecord(String targetNodeID)
long getCallTimeout()
Copyright © 2017 JBoss by Red Hat. All rights reserved.