akka.contrib.pattern
Class ShardCoordinator.RebalanceWorker

java.lang.Object
  extended by akka.contrib.pattern.ShardCoordinator.RebalanceWorker
All Implemented Interfaces:
Actor
Enclosing class:
ShardCoordinator

public static class ShardCoordinator.RebalanceWorker
extends java.lang.Object
implements Actor

INTERNAL API. Rebalancing process is performed by this actor. It sends ShardCoordinator.Internal$.BeginHandOff to all ShardRegion actors followed by ShardCoordinator.Internal$.BeginHandOff to the ShardRegion responsible for the shard. When the handoff is completed it sends RebalanceDone to its parent ShardCoordinator. If the process takes longer than the handOffTimeout it also sends RebalanceDone.


Nested Class Summary
 
Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$
 
Constructor Summary
ShardCoordinator.RebalanceWorker(java.lang.String shard, ActorRef from, scala.concurrent.duration.FiniteDuration handOffTimeout, scala.collection.immutable.Set<ActorRef> regions)
           
 
Method Summary
 void done(boolean ok)
           
 scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
          This defines the initial actor behavior, it must return a partial function with the actor logic.
 scala.collection.immutable.Set<ActorRef> remaining()
           
 scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> stoppingShard()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface akka.actor.Actor
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, postStop, preRestart, preStart, self, sender, supervisorStrategy, unhandled
 

Constructor Detail

ShardCoordinator.RebalanceWorker

public ShardCoordinator.RebalanceWorker(java.lang.String shard,
                                        ActorRef from,
                                        scala.concurrent.duration.FiniteDuration handOffTimeout,
                                        scala.collection.immutable.Set<ActorRef> regions)
Method Detail

remaining

public scala.collection.immutable.Set<ActorRef> remaining()

receive

public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
Description copied from interface: Actor
This defines the initial actor behavior, it must return a partial function with the actor logic.

Specified by:
receive in interface Actor
Returns:
(undocumented)

stoppingShard

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

done

public void done(boolean ok)