akka.contrib.pattern
Class ShardCoordinator.RebalanceWorker

java.lang.Object
  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)