org.codehaus.wadi.servicespace.basic
Class BasicServiceSpaceDispatcher.BasicServiceSpaceCluster

java.lang.Object
  extended by org.codehaus.wadi.group.impl.AbstractCluster
      extended by org.codehaus.wadi.servicespace.basic.BasicServiceSpaceDispatcher.BasicServiceSpaceCluster
All Implemented Interfaces:
Cluster
Enclosing class:
BasicServiceSpaceDispatcher

protected class BasicServiceSpaceDispatcher.BasicServiceSpaceCluster
extends AbstractCluster


Field Summary
 
Fields inherited from class org.codehaus.wadi.group.impl.AbstractCluster
addressToPeer, backendKeyToPeer, clusterName, clusterPeer, clusterThreadLocal, dispatcher, localPeer, localPeerName, log
 
Constructor Summary
BasicServiceSpaceDispatcher.BasicServiceSpaceCluster()
           
 
Method Summary
protected  Peer createPeerFromPeerSerialization(java.lang.Object backend)
           
protected  java.lang.Object extractKeyFromPeerSerialization(java.lang.Object backend)
           
 Address getAddress()
           
 LocalPeer getLocalPeer()
           
 Peer getPeerFromAddress(Address address)
           
 void start()
           
 void stop()
           
 
Methods inherited from class org.codehaus.wadi.group.impl.AbstractCluster
addClusterListener, get, getClusterName, getDispatcher, getPeer, getPeerCount, getPeerFromBackEndKey, getRemotePeers, notifyMembershipChanged, removeClusterListener, waitOnMembershipCount
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

BasicServiceSpaceDispatcher.BasicServiceSpaceCluster

public BasicServiceSpaceDispatcher.BasicServiceSpaceCluster()
Method Detail

extractKeyFromPeerSerialization

protected java.lang.Object extractKeyFromPeerSerialization(java.lang.Object backend)
Specified by:
extractKeyFromPeerSerialization in class AbstractCluster

createPeerFromPeerSerialization

protected Peer createPeerFromPeerSerialization(java.lang.Object backend)
Specified by:
createPeerFromPeerSerialization in class AbstractCluster

start

public void start()
           throws ClusterException
Throws:
ClusterException

stop

public void stop()
          throws ClusterException
Throws:
ClusterException

getAddress

public Address getAddress()

getLocalPeer

public LocalPeer getLocalPeer()

getPeerFromAddress

public Peer getPeerFromAddress(Address address)


Copyright © 2011. All Rights Reserved.