Package akka.cluster.sharding.internal
Class EventSourcedRememberEntitiesProvider
- java.lang.Object
-
- akka.cluster.sharding.internal.EventSourcedRememberEntitiesProvider
-
- All Implemented Interfaces:
RememberEntitiesProvider
public final class EventSourcedRememberEntitiesProvider extends java.lang.Object implements RememberEntitiesProvider
INTERNAL API
-
-
Constructor Summary
Constructors Constructor Description EventSourcedRememberEntitiesProvider(java.lang.String typeName, ClusterShardingSettings settings)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Props
coordinatorStoreProps()
Called once per started shard coordinator to create the remember entities coordinator store.Props
shardStoreProps(java.lang.String shardId)
Called once per started shard to create the remember entities shard store
-
-
-
Constructor Detail
-
EventSourcedRememberEntitiesProvider
public EventSourcedRememberEntitiesProvider(java.lang.String typeName, ClusterShardingSettings settings)
-
-
Method Detail
-
coordinatorStoreProps
public Props coordinatorStoreProps()
Description copied from interface:RememberEntitiesProvider
Called once per started shard coordinator to create the remember entities coordinator store.Note that this is not used for the deprecated persistent coordinator which has its own impl for keeping track of remembered shards.
- Specified by:
coordinatorStoreProps
in interfaceRememberEntitiesProvider
- Returns:
- an actor that handles the protocol defined in
RememberEntitiesCoordinatorStore
-
shardStoreProps
public Props shardStoreProps(java.lang.String shardId)
Description copied from interface:RememberEntitiesProvider
Called once per started shard to create the remember entities shard store- Specified by:
shardStoreProps
in interfaceRememberEntitiesProvider
- Returns:
- an actor that handles the protocol defined in
RememberEntitiesShardStore
-
-