|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjava.util.Observable
org.jboss.messaging.core.distributed.replicator.ReplicatorTopology
The Observers interested in topology changes should register here.
Field Summary | |
protected Replicator |
peer
|
protected java.util.Map |
topology
|
Method Summary | |
void |
aquireInitialTopology(RpcDispatcher dispatcher)
|
Address |
getAddress(java.io.Serializable outputPeerID)
|
java.io.Serializable |
getID()
Return the ID under which server object is registered with the RpcServer. |
java.util.Set |
getView()
Returns a copy of the current view. |
java.util.Map |
getViewMap()
Returns a copy of the current view map. |
void |
outputPeerJoins(java.io.Serializable joiningPeerID,
Address address)
Remote method invoked by an output peer on all input peers' topologies when joining the replicator. |
void |
outputPeerLeaves(java.io.Serializable leavingPeerID)
Remote method invoked by a leaving output peer on all topologies. |
void |
registerTopologyListener(java.util.Observer observer)
|
void |
stop()
Frees up resources and detaches the observers. |
java.lang.String |
toString()
|
Methods inherited from class java.util.Observable |
addObserver, clearChanged, countObservers, deleteObserver, deleteObservers, hasChanged, notifyObservers, notifyObservers, setChanged |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
protected Replicator peer
protected java.util.Map topology
Method Detail |
public java.io.Serializable getID()
ServerFacade
getID
in interface ServerFacade
public void outputPeerJoins(java.io.Serializable joiningPeerID, Address address) throws java.lang.Exception
org.jboss.messaging.core.distributed.replicator.ReplicatorTopologyServerDelegate
outputPeerJoins
in interface org.jboss.messaging.core.distributed.replicator.ReplicatorTopologyServerDelegate
java.lang.Exception
- - negative acknowledgment. The join is vetoed (willingly or unwillingly)
by this member.public void outputPeerLeaves(java.io.Serializable leavingPeerID)
org.jboss.messaging.core.distributed.replicator.ReplicatorTopologyServerDelegate
outputPeerLeaves
in interface org.jboss.messaging.core.distributed.replicator.ReplicatorTopologyServerDelegate
public java.util.Set getView()
org.jboss.messaging.core.distributed.replicator.ReplicatorTopologyServerDelegate
getView
in interface org.jboss.messaging.core.distributed.replicator.ReplicatorTopologyServerDelegate
public java.util.Map getViewMap()
org.jboss.messaging.core.distributed.replicator.ReplicatorTopologyServerDelegate
getViewMap
in interface org.jboss.messaging.core.distributed.replicator.ReplicatorTopologyServerDelegate
public Address getAddress(java.io.Serializable outputPeerID)
public void aquireInitialTopology(RpcDispatcher dispatcher) throws DistributedException
DistributedException
public void registerTopologyListener(java.util.Observer observer)
public void stop()
public java.lang.String toString()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |