org.codehaus.wadi.group.impl
Class AbstractCluster
java.lang.Object
org.codehaus.wadi.group.impl.AbstractCluster
- All Implemented Interfaces:
- Cluster
public abstract class AbstractCluster
- extends java.lang.Object
- implements Cluster
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
_cluster
public static final java.lang.ThreadLocal _cluster
_log
protected final org.apache.commons.logging.Log _log
_addressToPeer
protected final java.util.Map _addressToPeer
_backendKeyToPeer
protected final java.util.Map _backendKeyToPeer
_clusterName
protected final java.lang.String _clusterName
_localPeerName
protected final java.lang.String _localPeerName
dispatcher
protected final AbstractDispatcher dispatcher
_clusterPeer
protected Peer _clusterPeer
_localPeer
protected LocalPeer _localPeer
AbstractCluster
public AbstractCluster(java.lang.String clusterName,
java.lang.String localPeerName,
AbstractDispatcher dispatcher)
getClusterName
public java.lang.String getClusterName()
- Specified by:
getClusterName
in interface Cluster
getDispatcher
public Dispatcher getDispatcher()
- Specified by:
getDispatcher
in interface Cluster
getRemotePeers
public java.util.Map getRemotePeers()
- Specified by:
getRemotePeers
in interface Cluster
getPeerCount
public int getPeerCount()
- Specified by:
getPeerCount
in interface Cluster
waitOnMembershipCount
public boolean waitOnMembershipCount(int membershipCount,
long timeout)
throws java.lang.InterruptedException
- Specified by:
waitOnMembershipCount
in interface Cluster
- Parameters:
membershipCount
- - when membership reaches this number or we timeout this method will returntimeout
- - the number of milliseconds to wait for membership to hit membershipCount
- Returns:
- whether or not expected membershipCount was hit within given time
- Throws:
java.lang.InterruptedException
addClusterListener
public void addClusterListener(ClusterListener listener)
- Specified by:
addClusterListener
in interface Cluster
removeClusterListener
public void removeClusterListener(ClusterListener listener)
- Specified by:
removeClusterListener
in interface Cluster
notifyMembershipChanged
protected void notifyMembershipChanged(java.util.Set<Peer> joiners,
java.util.Set<Peer> leavers)
get
public static Peer get(java.lang.Object serializedPeer)
getPeer
public Peer getPeer(java.lang.Object serializedPeer)
getPeerFromBackEndKey
public Peer getPeerFromBackEndKey(java.lang.Object backEndKey)
createPeerFromPeerSerialization
protected abstract Peer createPeerFromPeerSerialization(java.lang.Object backend)
extractKeyFromPeerSerialization
protected abstract java.lang.Object extractKeyFromPeerSerialization(java.lang.Object backend)
Copyright © 2008. All Rights Reserved.