|
|||||||||
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<ClusterListener> |
listeners
|
Constructor Summary | |
---|---|
TribesCluster(byte[] clusterDomain,
TribesDispatcher dispatcher,
java.lang.String localPeerName,
PeerInfo localPeerinfo)
|
|
TribesCluster(byte[] clusterDomain,
TribesDispatcher dispatcher,
java.lang.String localPeerName,
PeerInfo localPeerinfo,
boolean disableMulticasting,
java.util.Properties mcastServiceProperties,
int receiverPort)
|
Method Summary | |
---|---|
void |
addClusterListener(ClusterListener listener)
addClusterListener |
protected void |
addStaticMembers(TribesDispatcher dispatcher)
|
protected void |
ensurePreferIPv4StackPropertyIsSet()
|
Address |
getAddress()
getAddress |
java.lang.String |
getClusterName()
|
Dispatcher |
getDispatcher()
|
long |
getInactiveTime()
|
LocalPeer |
getLocalPeer()
getLocalPeer |
int |
getPeerCount()
getPeerCount |
Peer |
getPeerFromAddress(Address address)
getPeerFromAddress |
java.util.Map<Address,Peer> |
getRemotePeers()
getRemotePeers |
void |
init()
|
void |
removeClusterListener(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<ClusterListener> listeners
protected boolean initialized
Constructor Detail |
---|
public TribesCluster(byte[] clusterDomain, TribesDispatcher dispatcher, java.lang.String localPeerName, PeerInfo localPeerinfo)
public TribesCluster(byte[] clusterDomain, TribesDispatcher dispatcher, java.lang.String localPeerName, PeerInfo localPeerinfo, boolean disableMulticasting, java.util.Properties mcastServiceProperties, int receiverPort)
Method Detail |
---|
public java.lang.String getClusterName()
getClusterName
in interface Cluster
public Dispatcher getDispatcher()
getDispatcher
in interface Cluster
public void addClusterListener(ClusterListener listener)
addClusterListener
in interface Cluster
listener
- ClusterListenerpublic Address getAddress()
getAddress
in interface Cluster
public long getInactiveTime()
public LocalPeer getLocalPeer()
getLocalPeer
in interface Cluster
public int getPeerCount()
getPeerCount
in interface Cluster
public Peer getPeerFromAddress(Address address)
getPeerFromAddress
in interface Cluster
address
- Address
public java.util.Map<Address,Peer> getRemotePeers()
getRemotePeers
in interface Cluster
public void removeClusterListener(ClusterListener listener)
removeClusterListener
in interface Cluster
listener
- ClusterListenerpublic void init() throws ClusterException
ClusterException
protected void ensurePreferIPv4StackPropertyIsSet()
public void start() throws ClusterException
start
in interface Cluster
ClusterException
public void stop() throws ClusterException
stop
in interface Cluster
ClusterException
public boolean waitOnMembershipCount(int membershipCount, long timeout) throws java.lang.InterruptedException
waitOnMembershipCount
in interface 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 |