akka.cluster.routing
Interface ClusterRouterActor

All Known Implementing Classes:
ClusterRouterGroupActor, ClusterRouterPoolActor

public interface ClusterRouterActor

INTERNAL API The router actor, subscribes to cluster events and adjusts the routees.


Method Summary
 void addMember(Member member)
           
 void addRoutees()
          Adds routees based on settings
 scala.collection.immutable.SortedSet<Address> availableNodes()
           
 Cluster cluster()
           
 scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> clusterReceive()
           
 Address fullAddress(Routee routee)
          Fills in self address for local ActorRef
 boolean isAvailable(Member m)
           
 scala.collection.immutable.SortedSet<Address> nodes()
           
 void postStop()
           
 void preStart()
           
 void removeMember(Member member)
           
 boolean satisfiesRole(scala.collection.immutable.Set<java.lang.String> memberRoles)
           
 ClusterRouterSettingsBase settings()
           
 

Method Detail

settings

ClusterRouterSettingsBase settings()

cluster

Cluster cluster()

preStart

void preStart()

postStop

void postStop()

nodes

scala.collection.immutable.SortedSet<Address> nodes()

isAvailable

boolean isAvailable(Member m)

satisfiesRole

boolean satisfiesRole(scala.collection.immutable.Set<java.lang.String> memberRoles)

availableNodes

scala.collection.immutable.SortedSet<Address> availableNodes()

fullAddress

Address fullAddress(Routee routee)
Fills in self address for local ActorRef

Parameters:
routee - (undocumented)
Returns:
(undocumented)

addRoutees

void addRoutees()
Adds routees based on settings


addMember

void addMember(Member member)

removeMember

void removeMember(Member member)

clusterReceive

scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> clusterReceive()