public interface ClusterConnection extends HornetQComponent, ClusterTopologyListener
Modifier and Type | Method and Description |
---|---|
void |
activate() |
void |
addClusterTopologyListener(ClusterTopologyListener listener) |
void |
announceBackup() |
String |
describe() |
void |
flushExecutor() |
TransportConfiguration |
getConnector() |
SimpleString |
getName() |
String |
getNodeID() |
Map<String,String> |
getNodes()
Only used for tests?
|
HornetQServer |
getServer() |
Topology |
getTopology() |
void |
informTopology() |
boolean |
isBackupAnnounced() |
boolean |
isNodeActive(String id) |
void |
nodeAnnounced(long eventUID,
String nodeID,
String nodeName,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean backup) |
void |
removeClusterTopologyListener(ClusterTopologyListener listener) |
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()
HornetQServer getServer()
void nodeAnnounced(long eventUID, String nodeID, String nodeName, Pair<TransportConfiguration,TransportConfiguration> connectorPair, boolean backup)
void addClusterTopologyListener(ClusterTopologyListener listener)
void removeClusterTopologyListener(ClusterTopologyListener listener)
TransportConfiguration getConnector()
Topology getTopology()
void flushExecutor()
String describe()
void informTopology()
boolean isBackupAnnounced()
void announceBackup()
boolean isNodeActive(String id)
Copyright © 2018 JBoss by Red Hat. All rights reserved.