Package akka.persistence

Interface Summary

AtLeastOnceDelivery	Mix-in this trait with your PersistentActor to send messages with at-least-once delivery semantics to destinations.
Delivered	Plugin API: confirmation message generated by receivers of ConfirmablePersistent messages by calling ConfirmablePersistent.confirm().
Eventsourced	INTERNAL API.
Eventsourced.PendingHandlerInvocation
EventsourcedProcessor	An event sourced processor.
PersistentActor	An persistent Actor - can be used to implement command or event sourcing.
PersistentConfirmation	Plugin API: confirmation entry written by journal plugins.
PersistentId	Plugin API: persistent message identifier.
PersistentRepr	Plugin API: representation of a persistent message in the journal plugin API.
PersistentView	A view replicates the persistent message stream of a PersistentActor.
PluginSpec
Processor	An actor that persists (journals) messages of type Persistent.
ProcessorImpl	INTERNAL API
Recovery	Recovery state machine that loads snapshots and replays messages.
Recovery.State	INTERNAL API.
Resequenceable	INTERNAL API
Snapshotter	Snapshot API on top of the internal snapshot protocol.
View	A view replicates the persistent message stream of a processor.

Class Summary

AbstractEventsourcedProcessor	Java API: compatible with lambda expressions (to be used with ReceiveBuilder): command handler.
AbstractPersistentActor	Java API: an persistent actor - can be used to implement command or event sourcing.
AbstractPersistentActorWithAtLeastOnceDelivery	Java API compatible with lambda expressions
AbstractPersistentView	Java API: compatible with lambda expressions (to be used with ReceiveBuilder)
AbstractProcessor	Java API: compatible with lambda expressions
AbstractView	Java API: compatible with lambda expressions (to be used with ReceiveBuilder)
AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot	Snapshot of current AtLeastOnceDelivery state.
AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot$
AtLeastOnceDelivery.Internal$
AtLeastOnceDelivery.UnconfirmedDelivery	Information about a message that has not been confirmed.
AtLeastOnceDelivery.UnconfirmedDelivery$
AtLeastOnceDelivery.UnconfirmedWarning
AtLeastOnceDelivery.UnconfirmedWarning$
AtLeastOnceDelivery$
Channel	A channel is used by Processors (and Views) for sending Persistent messages to destinations.
Channel$
ChannelSettings	A Channel configuration object.
ChannelSettings$
ConfirmablePersistent	Persistent message that has been delivered by a Channel or PersistentChannel.
ConfirmablePersistent$
ConfirmablePersistentImpl	INTERNAL API.
ConfirmablePersistentImpl$	INTERNAL API.
Deliver	Instructs a Channel or PersistentChannel to deliver a persistent message to a destination.
Deliver$
DeliveredByChannel	Plugin API.
DeliveredByChannel$
DeliveredByChannelBatching	INTERNAL API.
DeliveredByPersistentChannel	Plugin API.
DeliveredByPersistentChannel$
DeliveredByPersistentChannelBatching	INTERNAL API.
Eventsourced.AsyncHandlerInvocation
Eventsourced.StashingHandlerInvocation
JournalProtocol	INTERNAL API.
JournalProtocol.DeleteMessages	Request to delete messages identified by messageIds.
JournalProtocol.DeleteMessages$
JournalProtocol.DeleteMessagesFailure	Reply message to a failed JournalProtocol.DeleteMessages request.
JournalProtocol.DeleteMessagesFailure$
JournalProtocol.DeleteMessagesSuccess	Reply message to a successful JournalProtocol.DeleteMessages request.
JournalProtocol.DeleteMessagesSuccess$
JournalProtocol.DeleteMessagesTo	Request to delete all persistent messages with sequence numbers up to toSequenceNr (inclusive).
JournalProtocol.DeleteMessagesTo$
JournalProtocol.LoopMessage	Request to loop a message back to persistent actor, without persisting the message.
JournalProtocol.LoopMessage$
JournalProtocol.LoopMessageSuccess	Reply message to a JournalProtocol.LoopMessage request.
JournalProtocol.LoopMessageSuccess$
JournalProtocol.ReadHighestSequenceNr	Request to read the highest stored sequence number of a given persistent actor.
JournalProtocol.ReadHighestSequenceNr$
JournalProtocol.ReadHighestSequenceNrFailure	Reply message to a failed JournalProtocol.ReadHighestSequenceNr request.
JournalProtocol.ReadHighestSequenceNrFailure$
JournalProtocol.ReadHighestSequenceNrSuccess	Reply message to a successful JournalProtocol.ReadHighestSequenceNr request.
JournalProtocol.ReadHighestSequenceNrSuccess$
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.ReplayMessagesSuccess$	Reply message to a successful JournalProtocol.ReplayMessages request.
JournalProtocol.WriteConfirmations	Request to write delivery confirmations.
JournalProtocol.WriteConfirmations$
JournalProtocol.WriteConfirmationsFailure	Reply message to a failed JournalProtocol.WriteConfirmations request.
JournalProtocol.WriteConfirmationsFailure$
JournalProtocol.WriteConfirmationsSuccess	Reply message to a successful JournalProtocol.WriteConfirmations request.
JournalProtocol.WriteConfirmationsSuccess$
JournalProtocol.WriteMessageFailure	Reply message to a failed JournalProtocol.WriteMessages request.
JournalProtocol.WriteMessageFailure$
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	INTERNAL API Message which can be resequenced by the Journal, but will not be persisted.
NonPersistentRepr$
Persistence	Persistence extension.
Persistence$	Persistence extension.
PersistenceFailure	Sent to a Processor if a journal fails to write a Persistent message.
PersistenceFailure$
PersistenceSettings	Persistence configuration.
Persistent	Persistent message.
Persistent$
PersistentBatch	Instructs a Processor to atomically write the contained Persistent messages to the journal.
PersistentBatch$
PersistentChannel	A PersistentChannel implements the same functionality as a Channel but additionally persists Deliver requests before they are served.
PersistentChannel$
PersistentChannelSettings	A PersistentChannel configuration object.
PersistentChannelSettings$
PersistentIdImpl	INTERNAL API.
PersistentIdImpl$
PersistentImpl	INTERNAL API.
PersistentImpl$
PersistentRepr$
ProcessorImpl$	INTERNAL API
Recover	Instructs a persistent actor to recover itself.
Recover$
RecoveryCompleted
RecoveryCompleted$	Sent to a Processor when the journal replay has been finished.
RecoveryFailure	Sent to a Processor if a journal fails to replay messages or fetch that processor's highest sequence number.
RecoveryFailure$
RedeliverFailure	Notification message to inform channel listeners about messages that have reached the maximum number of redeliveries.
RedeliverFailure$
Redelivery	Redelivery process used by ReliableDelivery.
ReliableDelivery	Reliably deliver messages contained in Deliver requests to their destinations.
ReliableDelivery.DeliveryAttempt
ReliableDelivery.DeliveryAttempt$
ReliableDelivery.Redeliver
ReliableDelivery.Redeliver$
ReliableDelivery$
RequestReader	Reads Deliver requests from the journal and processes them.
RequestWriter	Writes Deliver requests to the journal.
RequestWriter.RequestsWritten$
RequestWriter$
Reset	Resets a PersistentChannel, forcing it to redeliver all unconfirmed persistent messages.
Reset$	Resets a PersistentChannel, forcing it to redeliver all unconfirmed persistent messages.
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.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$
UntypedEventsourcedProcessor	Java API: an event sourced processor.
UntypedPersistentActor	Java API: an persistent actor - can be used to implement command or event sourcing.
UntypedPersistentActorWithAtLeastOnceDelivery	Java API: Use this class instead of UntypedPersistentActor to send messages with at-least-once delivery semantics to destinations.
UntypedPersistentView	Java API.
UntypedProcessor	Java API: an actor that persists (journals) messages of type Persistent.
UntypedView	Java API.
Update	Instructs a PersistentView to update itself.
Update$

Exception Summary

AtLeastOnceDelivery.MaxUnconfirmedMessagesExceededException
ResetException	Exception thrown by a PersistentChannel child actor to re-initiate delivery.