SettingsManager

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. final def eq(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

16. def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

17. def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

18. final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

19. def handleCustomMessage(msg: ClusterListenerMessage): Unit

    Overriding of the ClusterListener's method that is needed to receive ClusterListenerMessages.

    Overriding of the ClusterListener's method that is needed to receive ClusterListenerMessages. This method forwards all the messages to all the assistants.

    msg

    the message received of type ClusterListenerMessage.

    Definition Classes

    SettingsManager → ClusterListener

20. def hashCode(): Int

    Definition Classes

    AnyRef → Any

21. final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

22. def log: LoggingAdapter

    Definition Classes

    ActorLogging

23. def memberRemovedAction(address: Address): Unit

    Overriding of the ClusterListener's method that is invoked when a member of the cluster is removed.

    Overriding of the ClusterListener's method that is invoked when a member of the cluster is removed. This method removes the assistant of the removed node from the map.

    address

    address of the node

    Definition Classes

    SettingsManager → ClusterListener

24. def memberUpAction(address: Address): Unit

    Overriding of the ClusterListener's method that is invoked when a member joins the cluster and is moved to up.

    Overriding of the ClusterListener's method that is invoked when a member joins the cluster and is moved to up. This method deploys an assistant on the new node and saves his reference. Then the assistant is initialized with the notifyNewAssistant method.

    address

    address of the node.

    Definition Classes

    SettingsManager → ClusterListener

25. final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

26. final def notify(): Unit

    Definition Classes

    AnyRef

27. final def notifyAll(): Unit

    Definition Classes

    AnyRef

28. def postRestart(reason: Throwable): Unit

    Definition Classes

    Actor

    Annotations

    @throws( classOf[java.lang.Exception] )

29. 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

30. def preRestart(reason: Throwable, message: Option[Any]): Unit

    Definition Classes

    Actor

    Annotations

    @throws( classOf[java.lang.Exception] )

31. 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

32. 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

33. val remoteAssistantMap: ConcurrentHashMap[Address, ActorRef]

34. implicit final val self: ActorRef

    Definition Classes

    Actor

35. final def sender(): ActorRef

    Definition Classes

    Actor

36. def supervisorStrategy: SupervisorStrategy

    Definition Classes

    Actor

37. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes

    AnyRef

38. def toString(): String

    Definition Classes

    AnyRef → Any

39. def unhandled(message: Any): Unit

    Definition Classes

    Actor

40. def unreachableMemberAction(address: Address): Unit

    Overriding of the ClusterListener's method that is invoked when a member of the cluster becomes unreachable.

    Overriding of the ClusterListener's method that is invoked when a member of the cluster becomes unreachable. This method removes the assistant of the unreachable node from the map.

    address

    address of the node

    Definition Classes

    SettingsManager → ClusterListener

41. final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

42. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

43. final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )