public static class ShardCoordinator.RebalanceWorker
extends java.lang.Object
implements akka.actor.Actor
BeginHandOff
to all ShardRegion
actors followed by
HandOff
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
.Constructor and Description |
---|
RebalanceWorker(java.lang.String shard,
akka.actor.ActorRef from,
scala.concurrent.duration.FiniteDuration handOffTimeout,
scala.collection.immutable.Set<akka.actor.ActorRef> regions) |
Modifier and Type | Method and Description |
---|---|
void |
done(boolean ok) |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive() |
scala.collection.immutable.Set<akka.actor.ActorRef> |
remaining() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
stoppingShard() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, postStop, preRestart, preStart, self, sender, supervisorStrategy, unhandled
public RebalanceWorker(java.lang.String shard, akka.actor.ActorRef from, scala.concurrent.duration.FiniteDuration handOffTimeout, scala.collection.immutable.Set<akka.actor.ActorRef> regions)
public scala.collection.immutable.Set<akka.actor.ActorRef> remaining()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
receive
in interface akka.actor.Actor
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> stoppingShard()
public void done(boolean ok)