Package akka.cluster

Class ClusterDomainEventPublisher

    • Constructor Detail

      • ClusterDomainEventPublisher

        public ClusterDomainEventPublisher()
    • Method Detail

      • akka$actor$Actor$_setter_$context_$eq

        protected void akka$actor$Actor$_setter_$context_$eq​(ActorContext x$1)
        Description copied from interface: Actor
        Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such as forward.

        WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

        ActorContext is the Scala API. getContext returns a AbstractActor.ActorContext, which is the Java API of the actor context.

        Specified by:
        akka$actor$Actor$_setter_$context_$eq in interface Actor
        Parameters:
        x$1 - (undocumented)
      • akka$actor$Actor$_setter_$self_$eq

        protected final void akka$actor$Actor$_setter_$self_$eq​(ActorRef x$1)
        Description copied from interface: Actor
        The 'self' field holds the ActorRef for this actor.

        Can be used to send messages to itself:
         self ! message
         
        Specified by:
        akka$actor$Actor$_setter_$self_$eq in interface Actor
        Parameters:
        x$1 - (undocumented)
      • clearState

        public void clearState()
      • cluster

        public Cluster cluster()
      • context

        public ActorContext context()
        Description copied from interface: Actor
        Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such as forward.

        WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

        ActorContext is the Scala API. getContext returns a AbstractActor.ActorContext, which is the Java API of the actor context.

        Specified by:
        context in interface Actor
        Returns:
        (undocumented)
      • membershipState_$eq

        public void membershipState_$eq​(MembershipState x$1)
      • postStop

        public void postStop()
        Description copied from interface: Actor
        User overridable callback.

        Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.
        Specified by:
        postStop in interface Actor
      • preRestart

        public void preRestart​(java.lang.Throwable reason,
                               scala.Option<java.lang.Object> message)
        Description copied from interface: Actor
        Scala API: User overridable callback: '''By default it disposes of all children and then calls postStop().'''
        Specified by:
        preRestart in interface Actor
        Parameters:
        reason - the Throwable that caused the restart to happen
        message - optionally the current message the actor processed when failing, if applicable

        Is called on a crashed Actor right BEFORE it is restarted to allow clean up of resources before Actor is terminated.
      • publish

        public void publish​(java.lang.Object event)
      • publishChanges

        public void publishChanges​(MembershipState newState)
      • publishDiff

        public void publishDiff​(MembershipState oldState,
                                MembershipState newState,
                                scala.Function1<java.lang.Object,​scala.runtime.BoxedUnit> pub)
      • receive

        public scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receive()
        Description copied from interface: Actor
        Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.
        Specified by:
        receive in interface Actor
        Returns:
        (undocumented)
      • self

        public final ActorRef self()
        Description copied from interface: Actor
        The 'self' field holds the ActorRef for this actor.

        Can be used to send messages to itself:
         self ! message
         
        Specified by:
        self in interface Actor
        Returns:
        (undocumented)
      • selfDc

        public java.lang.String selfDc()
      • sendCurrentClusterState

        public void sendCurrentClusterState​(ActorRef receiver)
        The current snapshot state corresponding to latest gossip to mimic what you would have seen if you were listening to the events.
        Parameters:
        receiver - (undocumented)
      • unsubscribe

        public void unsubscribe​(ActorRef subscriber,
                                scala.Option<java.lang.Class<?>> to)