Class ReplicatedShardingImpl<M>
- java.lang.Object
-
- akka.cluster.sharding.typed.internal.ReplicatedShardingImpl<M>
-
- All Implemented Interfaces:
ReplicatedSharding<M>
public final class ReplicatedShardingImpl<M> extends java.lang.Object implements ReplicatedSharding<M>
INTERNAL API
-
-
Constructor Summary
Constructors Constructor Description ReplicatedShardingImpl(ClusterSharding sharding, scala.collection.immutable.Map<ReplicaId,scala.Tuple3<EntityTypeKey<M>,scala.Option<java.lang.String>,java.lang.String>> replicaTypeKeys)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description scala.collection.immutable.Map<ReplicaId,EntityRef<M>>
entityRefsFor(java.lang.String entityId)
Scala API: Returns the entity ref for each replica for user defined routing/replica selectionjava.util.Map<ReplicaId,EntityRef<M>>
getEntityRefsFor(java.lang.String entityId)
Java API: Returns the entity ref for each replica for user defined routing/replica selection
-
-
-
Constructor Detail
-
ReplicatedShardingImpl
public ReplicatedShardingImpl(ClusterSharding sharding, scala.collection.immutable.Map<ReplicaId,scala.Tuple3<EntityTypeKey<M>,scala.Option<java.lang.String>,java.lang.String>> replicaTypeKeys)
-
-
Method Detail
-
entityRefsFor
public scala.collection.immutable.Map<ReplicaId,EntityRef<M>> entityRefsFor(java.lang.String entityId)
Description copied from interface:ReplicatedSharding
Scala API: Returns the entity ref for each replica for user defined routing/replica selection- Specified by:
entityRefsFor
in interfaceReplicatedSharding<M>
-
getEntityRefsFor
public java.util.Map<ReplicaId,EntityRef<M>> getEntityRefsFor(java.lang.String entityId)
Description copied from interface:ReplicatedSharding
Java API: Returns the entity ref for each replica for user defined routing/replica selection- Specified by:
getEntityRefsFor
in interfaceReplicatedSharding<M>
-
-