Class ShardCoordinator.RebalanceWorker

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

    public static class ShardCoordinator.RebalanceWorker
    extends java.lang.Object
    implements Actor, ActorLogging, Timers
    INTERNAL API. Rebalancing process is performed by this actor. It sends BeginHandOff to all ShardRegion actors followed by HandOff to the ShardRegion responsible for the shard. When the handoff is completed it sends akka.cluster.sharding.ShardCoordinator.RebalanceDone to its parent ShardCoordinator. If the process takes longer than the handOffTimeout it also sends akka.cluster.sharding.ShardCoordinator.RebalanceDone.
    • Constructor Detail

      • RebalanceWorker

        public RebalanceWorker​(java.lang.String shard,
                               ActorRef from,
                               scala.concurrent.duration.FiniteDuration handOffTimeout,
                               scala.collection.immutable.Set<ActorRef> regions)
    • 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
      • stoppingShard

        public scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> stoppingShard()
      • done

        public void done​(boolean ok)