server.DistributionStrategy

RoundRobinAddresses

class RoundRobinAddresses extends ClusterListener

RoundRobinAddresses is a class that offers a RoundRobin strategy to select. the next address for actor deployment.

Linear Supertypes
ClusterListener, ActorLogging, Actor, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. RoundRobinAddresses
  2. ClusterListener
  3. ActorLogging
  4. Actor
  5. AnyRef
  6. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new RoundRobinAddresses()

Type Members

  1. type Receive = PartialFunction[Any, Unit]

    Definition Classes
    Actor

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

    Definition Classes
    AnyRef → Any
  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. var addresses: ArrayList[Address]

    Definition Classes
    ClusterListener
  7. def aroundPostRestart(reason: Throwable): Unit

    Attributes
    protected[akka]
    Definition Classes
    Actor
  8. def aroundPostStop(): Unit

    Attributes
    protected[akka]
    Definition Classes
    Actor
  9. def aroundPreRestart(reason: Throwable, message: Option[Any]): Unit

    Attributes
    protected[akka]
    Definition Classes
    Actor
  10. def aroundPreStart(): Unit

    Attributes
    protected[akka]
    Definition Classes
    Actor
  11. def aroundReceive(receive: akka.actor.Actor.Receive, msg: Any): Unit

    Attributes
    protected[akka]
    Definition Classes
    Actor
  12. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  13. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  14. implicit val context: ActorContext

    Definition Classes
    Actor
  15. var counter: Integer

  16. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  17. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  18. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  19. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  20. def handleCustomMessage(msg: ClusterListenerMessage): Unit

    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.

    msg

    the message received of Any type.

    Definition Classes
    RoundRobinAddressesClusterListener
  21. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  22. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  23. def log: LoggingAdapter

    Definition Classes
    ActorLogging
  24. def memberRemovedAction(msg: Address): Unit

    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

    Definition Classes
    RoundRobinAddressesClusterListener
  25. def memberUpAction(msg: Address): Unit

    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

    Definition Classes
    RoundRobinAddressesClusterListener
  26. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  27. def nextAddress(): Address

    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.

    returns

    the address chosen of type akka.actor.Address.

  28. final def notify(): Unit

    Definition Classes
    AnyRef
  29. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  30. def postRestart(reason: Throwable): Unit

    Definition Classes
    Actor
    Annotations
    @throws( classOf[java.lang.Exception] )
  31. def postStop(): Unit

    Overriding of the postStop method of Actor.

    Overriding of the postStop method of Actor. When he is stopped he unsubscribes itself from cluster.

    Definition Classes
    ClusterListener → Actor
  32. def preRestart(reason: Throwable, message: Option[Any]): Unit

    Definition Classes
    Actor
    Annotations
    @throws( classOf[java.lang.Exception] )
  33. def preStart(): Unit

    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.

    Definition Classes
    ClusterListener → Actor
  34. def receive: PartialFunction[Any, Unit]

    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.

    Definition Classes
    ClusterListener → Actor
  35. implicit final val self: ActorRef

    Definition Classes
    Actor
  36. final def sender(): ActorRef

    Definition Classes
    Actor
  37. def supervisorStrategy: SupervisorStrategy

    Definition Classes
    Actor
  38. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  39. def toString(): String

    Definition Classes
    AnyRef → Any
  40. def unhandled(message: Any): Unit

    Definition Classes
    Actor
  41. def unreachableMemberAction(msg: Address): Unit

    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

    Definition Classes
    RoundRobinAddressesClusterListener
  42. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  43. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  44. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from ClusterListener

Inherited from ActorLogging

Inherited from Actor

Inherited from AnyRef

Inherited from Any

Ungrouped