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

Modifier and Type	Method and Description
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()