public final class Topology extends Object
Constructor and Description |
---|
Topology(Object owner) |
Topology(Object owner,
Executor executor) |
Modifier and Type | Method and Description |
---|---|
void |
addClusterTopologyListener(ClusterTopologyListener listener) |
void |
clear()
It will remove all elements as if it haven't received anyone from the server.
|
String |
describe() |
TransportConfiguration |
getBackupForConnector(Connector connector) |
TopologyMemberImpl |
getMember(String nodeID) |
TopologyMemberImpl |
getMember(TransportConfiguration configuration) |
Collection<TopologyMemberImpl> |
getMembers() |
boolean |
isEmpty() |
void |
removeClusterTopologyListener(ClusterTopologyListener listener) |
void |
resendNode(String nodeId)
After the node is started, it will resend the notifyLive a couple of times to avoid gossip between two servers
|
void |
sendTopology(ClusterTopologyListener listener) |
void |
setOwner(Object owner)
The owner exists mainly for debug purposes.
|
String |
toString() |
void |
updateAsLive(String nodeId,
TopologyMemberImpl memberInput)
This is called by the server when the node is activated from backup state.
|
TopologyMemberImpl |
updateBackup(TopologyMemberImpl memberInput)
This is called by the server when the node is activated from backup state.
|
boolean |
updateMember(long uniqueEventID,
String nodeId,
TopologyMemberImpl memberInput) |
public Topology(Object owner)
public void clear()
public void addClusterTopologyListener(ClusterTopologyListener listener)
public void removeClusterTopologyListener(ClusterTopologyListener listener)
public void updateAsLive(String nodeId, TopologyMemberImpl memberInput)
public void resendNode(String nodeId)
nodeId
- public TopologyMemberImpl updateBackup(TopologyMemberImpl memberInput)
public boolean updateMember(long uniqueEventID, String nodeId, TopologyMemberImpl memberInput)
uniqueEventID
- an unique identifier for when the change was made. We will use current
time millis for starts, and a ++ of that number for shutdown.nodeId
- memberInput
- true
if an update did take place. Note that backups are *always* updated.public void sendTopology(ClusterTopologyListener listener)
public TopologyMemberImpl getMember(String nodeID)
public TopologyMemberImpl getMember(TransportConfiguration configuration)
public boolean isEmpty()
public Collection<TopologyMemberImpl> getMembers()
public String describe()
public void setOwner(Object owner)
public TransportConfiguration getBackupForConnector(Connector connector)
Copyright © 2017 JBoss by Red Hat. All rights reserved.