Class ShardCoordinator.Internal$.BeginHandOff
- java.lang.Object
-
- org.apache.pekko.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.Serializable
ShardCoordinator
initiates rebalancing process by sending this message to all registeredShardRegion
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 withShardCoordinator.Internal$.BeginHandOffAck
. When all have replied theShardCoordinator
continues by sendingHandOff
to theShardRegion
responsible 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 org.apache.pekko.cluster.sharding.ShardCoordinator.Internal.BeginHandOff
apply(java.lang.String shard)
boolean
canEqual(java.lang.Object x$1)
org.apache.pekko.cluster.sharding.ShardCoordinator.Internal.BeginHandOff
copy(java.lang.String shard)
java.lang.String
copy$default$1()
boolean
equals(java.lang.Object x$1)
int
hashCode()
int
productArity()
java.lang.Object
productElement(int x$1)
java.lang.String
productElementName(int x$1)
scala.collection.Iterator<java.lang.Object>
productIterator()
java.lang.String
productPrefix()
java.lang.String
shard()
java.lang.String
toString()
static scala.Option<java.lang.String>
unapply(org.apache.pekko.cluster.sharding.ShardCoordinator.Internal.BeginHandOff x$0)
-
-
-
Method Detail
-
apply
public static org.apache.pekko.cluster.sharding.ShardCoordinator.Internal.BeginHandOff apply(java.lang.String shard)
-
unapply
public static scala.Option<java.lang.String> unapply(org.apache.pekko.cluster.sharding.ShardCoordinator.Internal.BeginHandOff x$0)
-
shard
public java.lang.String shard()
-
copy
public org.apache.pekko.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:
productPrefix
in interfacescala.Product
-
productArity
public int productArity()
- Specified by:
productArity
in interfacescala.Product
-
productElement
public java.lang.Object productElement(int x$1)
- Specified by:
productElement
in interfacescala.Product
-
productIterator
public scala.collection.Iterator<java.lang.Object> productIterator()
- Specified by:
productIterator
in interfacescala.Product
-
canEqual
public boolean canEqual(java.lang.Object x$1)
- Specified by:
canEqual
in interfacescala.Equals
-
productElementName
public java.lang.String productElementName(int x$1)
- Specified by:
productElementName
in interfacescala.Product
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
equals
public boolean equals(java.lang.Object x$1)
- Specified by:
equals
in interfacescala.Equals
- Overrides:
equals
in classjava.lang.Object
-
-