Package org.apache.activemq.artemis.core.client.impl

Class Topology

java.lang.Object

org.apache.activemq.artemis.core.client.impl.Topology

public final class Topology
extends Object

Constructor Summary

Constructors

Constructor	Description
Topology(Object owner)
Topology(Object owner, Executor executor)

Method Summary

Modifier and Type	Method	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(RemotingConnection rc)
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)
Topology	setExecutor(Executor executor)
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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

Topology

public Topology(Object owner)

Topology

public Topology(Object owner,
                Executor executor)

Method Detail

setExecutor

public Topology setExecutor(Executor executor)

clear

public void clear()

It will remove all elements as if it haven't received anyone from the server.

addClusterTopologyListener

public void addClusterTopologyListener(ClusterTopologyListener listener)

removeClusterTopologyListener

public void removeClusterTopologyListener(ClusterTopologyListener listener)

updateAsLive

public void updateAsLive(String nodeId,
                         TopologyMemberImpl memberInput)

This is called by the server when the node is activated from backup state. It will always succeed

resendNode

public void resendNode(String nodeId)

After the node is started, it will resend the notifyLive a couple of times to avoid gossip between two servers

Parameters:

nodeId -

updateBackup

public TopologyMemberImpl updateBackup(TopologyMemberImpl memberInput)

This is called by the server when the node is activated from backup state. It will always succeed

updateMember

public boolean updateMember(long uniqueEventID,
                            String nodeId,
                            TopologyMemberImpl memberInput)

Parameters:

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 -

Returns:

true if an update did take place. Note that backups are *always* updated.

sendTopology

public void sendTopology(ClusterTopologyListener listener)

getMember

public TopologyMemberImpl getMember(String nodeID)

getMember

public TopologyMemberImpl getMember(RemotingConnection rc)

isEmpty

public boolean isEmpty()

getMembers

public Collection<TopologyMemberImpl> getMembers()

describe

public String describe()

setOwner

public void setOwner(Object owner)

The owner exists mainly for debug purposes. When enabling logging and tracing, the Topology updates will include the owner, what will enable to identify what instances are receiving the updates, what will enable better debugging.

getBackupForConnector

public TransportConfiguration getBackupForConnector(Connector connector)

toString

public String toString()

Overrides:

toString in class Object