org.hornetq.core.client.impl

Class Topology

java.lang.Object

org.hornetq.core.client.impl.Topology

All Implemented Interfaces:

Serializable

public class Topology
extends Object
implements Serializable

Author:

Andy Taylor, Clebert Suconic Created Aug 16, 2010

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Topology(Object owner)

Method Summary

Methods

Modifier and Type	Method and Description
void	addClusterTopologyListener(ClusterTopologyListener listener)
String	describe()
String	describe(String text)
protected void	execute(Runnable runnable)
TransportConfiguration	getBackupForConnector(TransportConfiguration connectorConfiguration)
TopologyMember	getMember(String nodeID)
Collection<TopologyMember>	getMembers()
boolean	isEmpty()
int	members()
int	nodes()
void	removeClusterTopologyListener(ClusterTopologyListener listener)
boolean	removeMember(long uniqueEventID, String nodeId)
void	sendMember(String nodeID) it will send the member to its listeners
void	sendTopology(ClusterTopologyListener listener)
void	setExecutor(Executor executor)
void	setOwner(Object owner) The owner exists mainly for debug purposes.
String	toString()
void	updateAsLive(String nodeId, TopologyMember memberInput) This is called by the server when the node is activated from backup state.
TopologyMember	updateBackup(String nodeId, TopologyMember memberInput) This is called by the server when the node is activated from backup state.
boolean	updateMember(long uniqueEventID, String nodeId, TopologyMember 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)

Method Detail

setExecutor

public void setExecutor(Executor executor)

addClusterTopologyListener

public void addClusterTopologyListener(ClusterTopologyListener listener)

removeClusterTopologyListener

public void removeClusterTopologyListener(ClusterTopologyListener listener)

updateAsLive

public void updateAsLive(String nodeId,
                TopologyMember memberInput)

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

updateBackup

public TopologyMember updateBackup(String nodeId,
                          TopologyMember 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,
                   TopologyMember memberInput)

Parameters:

uniqueIdentifier - 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:

removeMember

public boolean removeMember(long uniqueEventID,
                   String nodeId)

execute

protected void execute(Runnable runnable)

sendMember

public void sendMember(String nodeID)

it will send the member to its listeners

Parameters:

nodeID -

member -

sendTopology

public void sendTopology(ClusterTopologyListener listener)

getMember

public TopologyMember getMember(String nodeID)

isEmpty

public boolean isEmpty()

getMembers

public Collection<TopologyMember> getMembers()

nodes

public int nodes()

describe

public String describe()

describe

public String describe(String text)

members

public int members()

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(TransportConfiguration connectorConfiguration)

toString

public String toString()

Overrides:

toString in class Object