Package org.apache.pekko.persistence

Interface Summary

Interface	Description
AbstractPersistentActorLike	INTERNAL API
AtLeastOnceDelivery	Scala API: Mix-in this trait with your PersistentActor to send messages with at-least-once delivery semantics to destinations.
AtLeastOnceDeliveryLike
CapabilityFlags
Eventsourced	INTERNAL API.
Eventsourced.PendingHandlerInvocation	INTERNAL API
Eventsourced.State
JournalCapabilityFlags
JournalProtocol.Message	Marker trait shared by internal journal messages.
JournalProtocol.Request	Internal journal command.
JournalProtocol.Response	Internal journal acknowledgement.
PersistenceIdentity	Identification of PersistentActor.
PersistenceRecovery
PersistenceStash
PersistentActor	Scala API: A persistent Actor - can be used to implement command or Event Sourcing.
PersistentEnvelope	INTERNAL API
PersistentRepr	Plugin API: representation of a persistent message in the journal plugin API.
PluginProvider<T,ScalaDsl,JavaDsl>	INTERNAL API
Protocol.Message	INTERNAL API.
RuntimePluginConfig
SnapshotProtocol.Message	Marker trait shared by internal snapshot messages.
SnapshotProtocol.Request	Internal snapshot command.
SnapshotProtocol.Response	Internal snapshot acknowledgement.
SnapshotStoreCapabilityFlags
Snapshotter	Snapshot API on top of the internal snapshot protocol.
StashOverflowStrategy	This defines how to handle the current received message which failed to stash, when the size of Stash exceeding the capacity of Stash.
StashOverflowStrategyConfigurator	Implement this interface in order to configure the stashOverflowStrategy for the internal stash of persistent actor.

Class Summary

Class	Description
AbstractPersistentActor	Java API: an persistent actor - can be used to implement command or Event Sourcing.
AbstractPersistentActorWithAtLeastOnceDelivery	Java API: compatible with lambda expressions
AbstractPersistentActorWithTimers	Java API: Combination of AbstractPersistentActor and pekko.actor.AbstractActorWithTimers.
AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot	Snapshot of current AtLeastOnceDelivery state.
AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot$
AtLeastOnceDelivery.Internal$	INTERNAL API
AtLeastOnceDelivery.UnconfirmedDelivery	Information about a message that has not been confirmed.
AtLeastOnceDelivery.UnconfirmedDelivery$
AtLeastOnceDelivery.UnconfirmedWarning
AtLeastOnceDelivery.UnconfirmedWarning$
AtLeastOnceDelivery$
AtomicWrite
AtomicWrite$
CapabilityFlag
CapabilityFlag$
DeleteMessagesFailure	Reply message to a failed JournalProtocol.DeleteMessagesTo request.
DeleteMessagesFailure$
DeleteMessagesSuccess	Reply message to a successful JournalProtocol.DeleteMessagesTo request.
DeleteMessagesSuccess$
DeleteSnapshotFailure	Sent to a PersistentActor after failed deletion of a snapshot.
DeleteSnapshotFailure$
DeleteSnapshotsFailure	Sent to a PersistentActor after failed deletion of a range of snapshots.
DeleteSnapshotsFailure$
DeleteSnapshotsSuccess	Sent to a PersistentActor after successful deletion of specified range of snapshots.
DeleteSnapshotsSuccess$
DeleteSnapshotSuccess	Sent to a PersistentActor after successful deletion of a snapshot.
DeleteSnapshotSuccess$
DiscardConfigurator
DiscardToDeadLetterStrategy	Discard the message to pekko.actor.DeadLetter.
DiscardToDeadLetterStrategy$	Discard the message to pekko.actor.DeadLetter.
Eventsourced.AsyncHandlerInvocation	INTERNAL API: does not force the actor to stash commands; Originates from either `persistAsync` or `defer` calls
Eventsourced.AsyncHandlerInvocation$
Eventsourced.RecoveryTick	INTERNAL API: message used to detect that recovery timed out
Eventsourced.RecoveryTick$
Eventsourced.StashingHandlerInvocation	INTERNAL API: forces actor to stash incoming commands until all these invocations are handled
Eventsourced.StashingHandlerInvocation$
Eventsourced$	INTERNAL API
JournalProtocol	INTERNAL API.
JournalProtocol.DeleteMessagesTo	Request to delete all persistent messages with sequence numbers up to toSequenceNr (inclusive).
JournalProtocol.DeleteMessagesTo$
JournalProtocol.LoopMessageSuccess	Reply message to a JournalProtocol.WriteMessages with a non-persistent message.
JournalProtocol.LoopMessageSuccess$
JournalProtocol.RecoverySuccess	Reply message to a successful JournalProtocol.ReplayMessages request.
JournalProtocol.RecoverySuccess$
JournalProtocol.ReplayedMessage	Reply message to a JournalProtocol.ReplayMessages request.
JournalProtocol.ReplayedMessage$
JournalProtocol.ReplayMessages	Request to replay messages to persistentActor.
JournalProtocol.ReplayMessages$
JournalProtocol.ReplayMessagesFailure	Reply message to a failed JournalProtocol.ReplayMessages request.
JournalProtocol.ReplayMessagesFailure$
JournalProtocol.WriteMessageFailure	Reply message to a failed JournalProtocol.WriteMessages request.
JournalProtocol.WriteMessageFailure$
JournalProtocol.WriteMessageRejected	Reply message to a rejected JournalProtocol.WriteMessages request.
JournalProtocol.WriteMessageRejected$
JournalProtocol.WriteMessages	Request to write messages.
JournalProtocol.WriteMessages$
JournalProtocol.WriteMessagesFailed	Reply message to a failed JournalProtocol.WriteMessages request.
JournalProtocol.WriteMessagesFailed$
JournalProtocol.WriteMessagesSuccessful$	Reply message to a successful JournalProtocol.WriteMessages request.
JournalProtocol.WriteMessageSuccess	Reply message to a successful JournalProtocol.WriteMessages request.
JournalProtocol.WriteMessageSuccess$
JournalProtocol$	INTERNAL API.
NonPersistentRepr$
Persistence	Persistence extension.
Persistence.PluginHolder$
Persistence$	Persistence extension provider.
PersistencePlugin$	INTERNAL API
PersistenceSettings	Persistence configuration.
PersistentImpl$
PersistentRepr$
PluginSpec
Protocol	INTERNAL API.
Protocol$	INTERNAL API.
Recovery	Recovery mode configuration object to be returned in PersistenceRecovery.recovery().
Recovery$
RecoveryCompleted
RecoveryCompleted$	Sent to a PersistentActor when the journal replay has been finished.
RecoveryPermitter$	INTERNAL API
ReplyToStrategy	Reply to sender with predefined response, and discard the received message silently.
ReplyToStrategy$
SaveSnapshotFailure	Sent to a PersistentActor after failed saving of a snapshot.
SaveSnapshotFailure$
SaveSnapshotSuccess	Sent to a PersistentActor after successful saving of a snapshot.
SaveSnapshotSuccess$
SelectedSnapshot	Plugin API: a selected snapshot matching SnapshotSelectionCriteria.
SelectedSnapshot$
SnapshotMetadata	Snapshot metadata.
SnapshotMetadata$
SnapshotOffer	Offers a PersistentActor a previously saved snapshot during recovery.
SnapshotOffer$
SnapshotProtocol	INTERNAL API.
SnapshotProtocol.DeleteSnapshot	Instructs snapshot store to delete a snapshot.
SnapshotProtocol.DeleteSnapshot$
SnapshotProtocol.DeleteSnapshots	Instructs snapshot store to delete all snapshots that match criteria.
SnapshotProtocol.DeleteSnapshots$
SnapshotProtocol.LoadSnapshot	Instructs a snapshot store to load a snapshot.
SnapshotProtocol.LoadSnapshot$
SnapshotProtocol.LoadSnapshotFailed	Reply message to a failed SnapshotProtocol.LoadSnapshot request.
SnapshotProtocol.LoadSnapshotFailed$
SnapshotProtocol.LoadSnapshotResult	Response message to a SnapshotProtocol.LoadSnapshot message.
SnapshotProtocol.LoadSnapshotResult$
SnapshotProtocol.SaveSnapshot	Instructs snapshot store to save a snapshot.
SnapshotProtocol.SaveSnapshot$
SnapshotProtocol$	INTERNAL API.
SnapshotSelectionCriteria	Selection criteria for loading and deleting snapshots.
SnapshotSelectionCriteria$
TestPayload
TestPayload$
TestSerializer
ThrowExceptionConfigurator
ThrowOverflowExceptionStrategy	Throw pekko.actor.StashOverflowException, hence the persistent actor will starting recovery if guarded by default supervisor strategy.
ThrowOverflowExceptionStrategy$	Throw pekko.actor.StashOverflowException, hence the persistent actor will starting recovery if guarded by default supervisor strategy.
TraitOrder	INTERNAL API
TraitOrder$	INTERNAL API

Exception Summary

Exception	Description
AtLeastOnceDelivery.MaxUnconfirmedMessagesExceededException
RecoveryTimedOut