Class ShardRegion.HandOffStopper

  • All Implemented Interfaces:
    Actor, ActorLogging, Timers
    Enclosing class:
    ShardRegion

    public static class ShardRegion.HandOffStopper
    extends java.lang.Object
    implements Actor, ActorLogging, Timers
    INTERNAL API. Sends stopMessage (e.g. PoisonPill) to the entities and when all of them have terminated it replies with ShardStopped. If the entities don't terminate after handoffTimeout it will try stopping them forcefully.
    • Constructor Detail

      • HandOffStopper

        public HandOffStopper​(java.lang.String typeName,
                              java.lang.String shard,
                              ActorRef replyTo,
                              scala.collection.immutable.Set<ActorRef> entities,
                              java.lang.Object stopMessage,
                              scala.concurrent.duration.FiniteDuration handoffTimeout)
    • Method Detail

      • 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
      • 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
      • 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
      • 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
      • remaining

        public scala.collection.immutable.Set<ActorRef> remaining()
      • remaining_$eq

        public void remaining_$eq​(scala.collection.immutable.Set<ActorRef> x$1)
      • 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