public class PersistentShard extends Shard implements akka.persistence.PersistentActor, akka.actor.ActorLogging
This actor creates children entity actors on demand that it is told to be
responsible for. It is used when rememberEntities
is enabled.
ClusterSharding extension
Shard.EntityStarted, Shard.EntityStarted$, Shard.EntityStopped, Shard.EntityStopped$, Shard.RestartEntity, Shard.RestartEntity$, Shard.ShardCommand, Shard.State, Shard.State$, Shard.StateChange
akka.persistence.Eventsourced.AsyncHandlerInvocation, akka.persistence.Eventsourced.AsyncHandlerInvocation$, akka.persistence.Eventsourced.PendingHandlerInvocation, akka.persistence.Eventsourced.ProcessingState, akka.persistence.Eventsourced.StashingHandlerInvocation, akka.persistence.Eventsourced.StashingHandlerInvocation$, akka.persistence.Eventsourced.State
Constructor and Description |
---|
PersistentShard(java.lang.String typeName,
java.lang.String shardId,
akka.actor.Props entityProps,
ClusterShardingSettings settings,
scala.PartialFunction<java.lang.Object,scala.Tuple2<java.lang.String,java.lang.Object>> extractEntityId,
scala.Function1<java.lang.Object,java.lang.String> extractShardId,
java.lang.Object handOffStopMessage) |
Modifier and Type | Method and Description |
---|---|
void |
deliverTo(java.lang.String id,
java.lang.Object msg,
java.lang.Object payload,
akka.actor.ActorRef snd) |
void |
entityTerminated(akka.actor.ActorRef ref) |
void |
initialized() |
java.lang.String |
journalPluginId() |
int |
persistCount() |
java.lang.String |
persistenceId() |
<A> void |
processChange(A event,
scala.Function1<A,scala.runtime.BoxedUnit> handler) |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receiveRecover() |
void |
saveSnapshotWhenNeeded() |
java.lang.String |
snapshotPluginId() |
deliverMessage, getEntity, handOff, handOffStopper, idByRef, messageBuffers, passivate, passivateCompleted, passivating, props, receiveCommand, receiveCoordinatorMessage, receiveShardCommand, receiveShardRegionCommand, receiveTerminated, refById, sendMsgBuffer, state, totalBufferSize
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$extension_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$instanceId_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$internalStash_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$maxMessageBatchSize_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$pendingInvocations_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$persistingEvents_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$processingCommands_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$unstashFilterPredicate_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$writerUuid_$eq, akka$persistence$Eventsourced$$_lastSequenceNr_$eq, akka$persistence$Eventsourced$$_lastSequenceNr, akka$persistence$Eventsourced$$currentState_$eq, akka$persistence$Eventsourced$$currentState, akka$persistence$Eventsourced$$eventBatch_$eq, akka$persistence$Eventsourced$$eventBatch, akka$persistence$Eventsourced$$extension, akka$persistence$Eventsourced$$instanceId, akka$persistence$Eventsourced$$internalStash, akka$persistence$Eventsourced$$journalBatch_$eq, akka$persistence$Eventsourced$$journalBatch, akka$persistence$Eventsourced$$maxMessageBatchSize, akka$persistence$Eventsourced$$pendingInvocations, akka$persistence$Eventsourced$$pendingStashingPersistInvocations_$eq, akka$persistence$Eventsourced$$pendingStashingPersistInvocations, akka$persistence$Eventsourced$$persistingEvents, akka$persistence$Eventsourced$$processingCommands, akka$persistence$Eventsourced$$sequenceNr_$eq, akka$persistence$Eventsourced$$sequenceNr, akka$persistence$Eventsourced$$unstashFilterPredicate, akka$persistence$Eventsourced$$writeInProgress_$eq, akka$persistence$Eventsourced$$writeInProgress, akka$persistence$Eventsourced$$writerUuid, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, deferAsync, deleteMessages, journal, lastSequenceNr, onPersistFailure, onPersistRejected, onRecoveryFailure, onReplaySuccess, persist, persist, persistAll, persistAllAsync, persistAsync, persistAsync, receiveCommand, recoveryFinished, recoveryRunning, snapshotSequenceNr, snapshotStore, snapshotterId, unhandled, unstashAll
deleteSnapshot, deleteSnapshots, loadSnapshot, saveSnapshot
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, context, postRestart, preStart, self, sender, supervisorStrategy
akka$actor$StashSupport$_setter_$akka$actor$StashSupport$$capacity_$eq, akka$actor$StashSupport$_setter_$mailbox_$eq, akka$actor$StashSupport$$capacity, akka$actor$StashSupport$$theStash_$eq, akka$actor$StashSupport$$theStash, clearStash, context, mailbox, prepend, self, stash, unstash, unstashAll
public PersistentShard(java.lang.String typeName, java.lang.String shardId, akka.actor.Props entityProps, ClusterShardingSettings settings, scala.PartialFunction<java.lang.Object,scala.Tuple2<java.lang.String,java.lang.Object>> extractEntityId, scala.Function1<java.lang.Object,java.lang.String> extractShardId, java.lang.Object handOffStopMessage)
public java.lang.String persistenceId()
persistenceId
in interface akka.persistence.PersistenceIdentity
public java.lang.String journalPluginId()
journalPluginId
in interface akka.persistence.PersistenceIdentity
public java.lang.String snapshotPluginId()
snapshotPluginId
in interface akka.persistence.PersistenceIdentity
public int persistCount()
public void initialized()
initialized
in class Shard
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
public <A> void processChange(A event, scala.Function1<A,scala.runtime.BoxedUnit> handler)
processChange
in class Shard
public void saveSnapshotWhenNeeded()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receiveRecover()
receiveRecover
in interface akka.persistence.Eventsourced
public void entityTerminated(akka.actor.ActorRef ref)
entityTerminated
in class Shard