Overriding of the abstract function of ClusterListener.
Overriding of the abstract function of ClusterListener. This let RoundRobinAddresses receive messages of Any type. The only type needed is RoundRobinAddress message.
the message received of Any type.
Hook function to perform a custom action when a member is removed from cluster
Hook function to perform a custom action when a member is removed from cluster
Hook function to perform a custom action when a new member is up in cluster
Hook function to perform a custom action when a new member is up in cluster
This method is a Round Robin strategy to select an address from the list.
This method is a Round Robin strategy to select an address from the list. It uses the module of counter of requests and number of nodes.
the address chosen of type akka.actor.Address.
Overriding of the postStop method of Actor.
Overriding of the postStop method of Actor. When he is stopped he unsubscribes itself from cluster.
Overriding of the preStart method of Actor.
Overriding of the preStart method of Actor. When created this actor subscribes itself to cluster. It also adds the address of his node to his list.
Receive method of the actor.
Receive method of the actor. This method receives gossip from cluster and the string "next". A "next" message is a request for an address given by nextAddress method. The messages from the cluster is used to keep updated the list of node addresses and the number of nodes.
Hook function to perform a custom action when a member in the cluster becomes unreachable
Hook function to perform a custom action when a member in the cluster becomes unreachable
RoundRobinAddresses is a class that offers a RoundRobin strategy to select. the next address for actor deployment.