Package org.apache.pekko.persistence
package org.apache.pekko.persistence
-
ClassDescriptionJava API: an persistent actor - can be used to implement command or Event Sourcing.INTERNAL APIJava API: compatible with lambda expressionsJava API: Combination of
AbstractPersistentActorandpekko.actor.AbstractActorWithTimers.Scala API: Mix-in this trait with yourPersistentActorto send messages with at-least-once delivery semantics to destinations.Snapshot of currentAtLeastOnceDeliverystate.INTERNAL APIInformation about a message that has not been confirmed.Not for user extensionReply message to a failedDeleteMessagesTorequest.Reply message to a successfulDeleteMessagesTorequest.Sent to aPersistentActorafter failed deletion of a snapshot.Sent to aPersistentActorafter failed deletion of a range of snapshots.Sent to aPersistentActorafter successful deletion of specified range of snapshots.Sent to aPersistentActorafter successful deletion of a snapshot.Discard the message topekko.actor.DeadLetter.Discard the message topekko.actor.DeadLetter.INTERNAL API.INTERNAL API: does not force the actor to stash commands; Originates from either `persistAsync` or `defer` callsINTERNAL APIINTERNAL API: message used to detect that recovery timed outINTERNAL API: forces actor to stash incoming commands until all these invocations are handledINTERNAL APIIn some use cases with projections and events by slice filtered events needs to be stored in the journal to keep the sequence numbers for a given persistence id gap free.In some use cases with projections and events by slice filtered events needs to be stored in the journal to keep the sequence numbers for a given persistence id gap free.INTERNAL API.Request to delete all persistent messages with sequence numbers up totoSequenceNr(inclusive).Reply message to aJournalProtocol.WriteMessageswith a non-persistent message.Marker trait shared by internal journal messages.Reply message to a successfulJournalProtocol.ReplayMessagesrequest.Acknowledges that the requester has processed the replayed messages emitted before the correspondingJournalProtocol.ReplayBatchReady.Cancels a bounded replay after its replay filter has failed.Signals that one bounded replay batch has been emitted.Associates a bounded replay response with the recovering actor incarnation that requested it.Reply message to aJournalProtocol.ReplayMessagesrequest.Request to replay messages topersistentActor.Cancels all bounded replays requested by the sender.Reply message to a failedJournalProtocol.ReplayMessagesrequest.Opts the sender in to bounded replay for the immediately followingJournalProtocol.ReplayMessagesrequest.Internal journal command.Internal journal acknowledgement.Reply message to a failedJournalProtocol.WriteMessagesrequest.Reply message to a rejectedJournalProtocol.WriteMessagesrequest.Request to write messages.Reply message to a failedJournalProtocol.WriteMessagesrequest.Reply message to a successfulJournalProtocol.WriteMessagesrequest.Reply message to a successfulJournalProtocol.WriteMessagesrequest.INTERNAL API.Persistence extension.Persistence extension provider.Identification ofPersistentActor.INTERNAL APIPersistence configuration.Scala API: A persistent Actor - can be used to implement command or Event Sourcing.INTERNAL APIPlugin API: representation of a persistent message in the journal plugin API.PluginProvider<T,ScalaDsl, JavaDsl> INTERNAL APIINTERNAL API.INTERNAL API.INTERNAL API.Recovery mode configuration object to be returned inPersistenceRecovery.recovery().Sent to aPersistentActorwhen the journal replay has been finished.INTERNAL APIReply to sender with predefined response, and discard the received message silently.Sent to aPersistentActorafter failed saving of a snapshot.Sent to aPersistentActorafter successful saving of a snapshot.Plugin API: a selected snapshot matchingSnapshotSelectionCriteria.Snapshot metadata.Offers aPersistentActora previously savedsnapshotduring recovery.INTERNAL API.Instructs snapshot store to delete a snapshot.Instructs snapshot store to delete all snapshots that matchcriteria.Instructs a snapshot store to load a snapshot.Reply message to a failedSnapshotProtocol.LoadSnapshotrequest.Response message to aSnapshotProtocol.LoadSnapshotmessage.Marker trait shared by internal snapshot messages.Internal snapshot command.Internal snapshot acknowledgement.Instructs snapshot store to save a snapshot.INTERNAL API.Selection criteria for loading and deleting snapshots.Snapshot API on top of the internal snapshot protocol.This defines how to handle the current received message which failed to stash, when the size of Stash exceeding the capacity of Stash.Implement this interface in order to configure the stashOverflowStrategy for the internal stash of persistent actor.Throwpekko.actor.StashOverflowException, hence the persistent actor will starting recovery if guarded by default supervisor strategy.Throwpekko.actor.StashOverflowException, hence the persistent actor will starting recovery if guarded by default supervisor strategy.INTERNAL APIINTERNAL API