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 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 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 © 2011. All Rights Reserved.