org.codehaus.wadi.group
Interface Cluster

All Known Implementing Classes:
AbstractCluster, VMLocalCluster

public interface Cluster

Version:
$Revision: 1603 $

Method Summary
 void addClusterListener(ClusterListener listener)
           
 Address getAddress()
           
 java.lang.String getClusterName()
           
 Dispatcher getDispatcher()
           
 LocalPeer getLocalPeer()
           
 int getPeerCount()
           
 Peer getPeerFromAddress(Address address)
           
 java.util.Map<Address,Peer> getRemotePeers()
           
 void removeClusterListener(ClusterListener listener)
           
 void start()
           
 void stop()
           
 boolean waitOnMembershipCount(int membershipCount, long timeout)
           
 

Method Detail

getClusterName

java.lang.String getClusterName()

getRemotePeers

java.util.Map<Address,Peer> getRemotePeers()

getPeerCount

int getPeerCount()

getLocalPeer

LocalPeer getLocalPeer()

getAddress

Address getAddress()

addClusterListener

void addClusterListener(ClusterListener listener)

removeClusterListener

void removeClusterListener(ClusterListener listener)

getDispatcher

Dispatcher getDispatcher()

start

void start()
           throws ClusterException
Throws:
ClusterException

stop

void stop()
          throws ClusterException
Throws:
ClusterException

waitOnMembershipCount

boolean waitOnMembershipCount(int membershipCount,
                              long timeout)
                              throws java.lang.InterruptedException
Parameters:
membershipCount - - when membership reaches this number or we timeout this method will return
timeout - - 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

getPeerFromAddress

Peer getPeerFromAddress(Address address)


Copyright © 2010. All Rights Reserved.