Package 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, java.io.SerializableShardCoordinatorinitiates rebalancing process by sending this message to all registeredShardRegionactors (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 withShardCoordinator.Internal$.BeginHandOffAck. When all have replied theShardCoordinatorcontinues by sendingHandOffto theShardRegionresponsible for the shard.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description BeginHandOff(java.lang.String shard)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static akka.cluster.sharding.ShardCoordinator.Internal.BeginHandOffapply(java.lang.String shard)booleancanEqual(java.lang.Object x$1)akka.cluster.sharding.ShardCoordinator.Internal.BeginHandOffcopy(java.lang.String shard)java.lang.Stringcopy$default$1()booleanequals(java.lang.Object x$1)inthashCode()intproductArity()java.lang.ObjectproductElement(int x$1)java.lang.StringproductElementName(int x$1)scala.collection.Iterator<java.lang.Object>productIterator()java.lang.StringproductPrefix()java.lang.Stringshard()java.lang.StringtoString()static scala.Option<java.lang.String>unapply(akka.cluster.sharding.ShardCoordinator.Internal.BeginHandOff x$0)
-
-
-
Method Detail
-
apply
public static akka.cluster.sharding.ShardCoordinator.Internal.BeginHandOff apply(java.lang.String shard)
-
unapply
public static scala.Option<java.lang.String> unapply(akka.cluster.sharding.ShardCoordinator.Internal.BeginHandOff x$0)
-
shard
public java.lang.String shard()
-
copy
public akka.cluster.sharding.ShardCoordinator.Internal.BeginHandOff copy(java.lang.String shard)
-
copy$default$1
public java.lang.String copy$default$1()
-
productPrefix
public java.lang.String productPrefix()
- Specified by:
productPrefixin interfacescala.Product
-
productArity
public int productArity()
- Specified by:
productArityin interfacescala.Product
-
productElement
public java.lang.Object productElement(int x$1)
- Specified by:
productElementin interfacescala.Product
-
productIterator
public scala.collection.Iterator<java.lang.Object> productIterator()
- Specified by:
productIteratorin interfacescala.Product
-
canEqual
public boolean canEqual(java.lang.Object x$1)
- Specified by:
canEqualin interfacescala.Equals
-
productElementName
public java.lang.String productElementName(int x$1)
- Specified by:
productElementNamein interfacescala.Product
-
hashCode
public int hashCode()
- Overrides:
hashCodein classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toStringin classjava.lang.Object
-
equals
public boolean equals(java.lang.Object x$1)
- Specified by:
equalsin interfacescala.Equals- Overrides:
equalsin classjava.lang.Object
-
-