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()