|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.codehaus.wadi.tribes.TribesCluster
public class TribesCluster
Nested Class Summary | |
---|---|
protected class |
TribesCluster.WadiListener
|
Field Summary | |
---|---|
protected org.apache.catalina.tribes.group.GroupChannel |
channel
|
protected boolean |
initialized
|
protected java.util.List<org.codehaus.wadi.group.ClusterListener> |
listeners
|
Constructor Summary | |
---|---|
TribesCluster(byte[] clusterDomain,
TribesDispatcher dispatcher,
java.lang.String localPeerName,
org.codehaus.wadi.group.PeerInfo localPeerinfo)
|
Method Summary | |
---|---|
void |
addClusterListener(org.codehaus.wadi.group.ClusterListener listener)
addClusterListener |
protected void |
addStaticMembers(TribesDispatcher dispatcher)
|
org.codehaus.wadi.group.Address |
getAddress()
getAddress |
java.lang.String |
getClusterName()
|
org.codehaus.wadi.group.Dispatcher |
getDispatcher()
|
long |
getInactiveTime()
|
org.codehaus.wadi.group.LocalPeer |
getLocalPeer()
getLocalPeer |
int |
getPeerCount()
getPeerCount |
org.codehaus.wadi.group.Peer |
getPeerFromAddress(org.codehaus.wadi.group.Address address)
getPeerFromAddress |
java.util.Map |
getRemotePeers()
getRemotePeers |
void |
init()
|
void |
removeClusterListener(org.codehaus.wadi.group.ClusterListener listener)
removeClusterListener |
void |
start()
start |
void |
stop()
stop |
boolean |
waitOnMembershipCount(int membershipCount,
long timeout)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected org.apache.catalina.tribes.group.GroupChannel channel
protected java.util.List<org.codehaus.wadi.group.ClusterListener> listeners
protected boolean initialized
Constructor Detail |
---|
public TribesCluster(byte[] clusterDomain, TribesDispatcher dispatcher, java.lang.String localPeerName, org.codehaus.wadi.group.PeerInfo localPeerinfo)
Method Detail |
---|
public java.lang.String getClusterName()
getClusterName
in interface org.codehaus.wadi.group.Cluster
public org.codehaus.wadi.group.Dispatcher getDispatcher()
getDispatcher
in interface org.codehaus.wadi.group.Cluster
public void addClusterListener(org.codehaus.wadi.group.ClusterListener listener)
addClusterListener
in interface org.codehaus.wadi.group.Cluster
listener
- ClusterListenerpublic org.codehaus.wadi.group.Address getAddress()
getAddress
in interface org.codehaus.wadi.group.Cluster
public long getInactiveTime()
public org.codehaus.wadi.group.LocalPeer getLocalPeer()
getLocalPeer
in interface org.codehaus.wadi.group.Cluster
public int getPeerCount()
getPeerCount
in interface org.codehaus.wadi.group.Cluster
public org.codehaus.wadi.group.Peer getPeerFromAddress(org.codehaus.wadi.group.Address address)
getPeerFromAddress
in interface org.codehaus.wadi.group.Cluster
address
- Address
public java.util.Map getRemotePeers()
getRemotePeers
in interface org.codehaus.wadi.group.Cluster
public void removeClusterListener(org.codehaus.wadi.group.ClusterListener listener)
removeClusterListener
in interface org.codehaus.wadi.group.Cluster
listener
- ClusterListenerpublic void init() throws org.codehaus.wadi.group.ClusterException
org.codehaus.wadi.group.ClusterException
public void start() throws org.codehaus.wadi.group.ClusterException
start
in interface org.codehaus.wadi.group.Cluster
org.codehaus.wadi.group.ClusterException
public void stop() throws org.codehaus.wadi.group.ClusterException
stop
in interface org.codehaus.wadi.group.Cluster
org.codehaus.wadi.group.ClusterException
public boolean waitOnMembershipCount(int membershipCount, long timeout) throws java.lang.InterruptedException
waitOnMembershipCount
in interface org.codehaus.wadi.group.Cluster
membershipCount
- - when membership reaches this number or we timeout this method will returntimeout
- - the number of milliseconds to wait for membership to hit membershipCount
java.lang.InterruptedException
protected void addStaticMembers(TribesDispatcher dispatcher)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |