akka.cluster.sharding

Class ShardCoordinator.Internal$.BeginHandOff

java.lang.Object

akka.cluster.sharding.ShardCoordinator.Internal$.BeginHandOff

All Implemented Interfaces:

java.io.Serializable, scala.Equals, scala.Product

Enclosing class:

ShardCoordinator.Internal$

public final class ShardCoordinator.Internal$.BeginHandOff
extends java.lang.Object
implements scala.Product, scala.Serializable

ShardCoordinator initiates rebalancing process by sending this message to all registered ShardRegion actors (including proxy only). They are supposed to discard their known location of the shard, i.e. start buffering incoming messages for the shard. They reply with ShardCoordinator.Internal$.BeginHandOffAck. When all have replied the ShardCoordinator continues by sending HandOff to the ShardRegion responsible for the shard.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
BeginHandOff(java.lang.String shard)

Method Summary

Modifier and Type	Method and Description
java.lang.String	shard()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface scala.Product

$init$, productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

BeginHandOff

public BeginHandOff(java.lang.String shard)

Method Detail

shard

public java.lang.String shard()