Package akka.persistence.journal

Interface Summary

AsyncRecovery	Asynchronous message replay and sequence number recovery interface.
AsyncWriteJournal	Abstract journal, optimized for asynchronous, non-blocking writes.
AsyncWriteProxy	INTERNAL API.
JournalPerfSpec	This spec measures execution times of the basic operations that an PersistentActor provides, using the provided Journal (plugin).
JournalSpec	This spec aims to verify custom akka-persistence Journal implementations.
SyncWriteJournal	Abstract journal, optimized for synchronous writes.
WriteJournalBase

Class Summary

AsyncWriteJournal.Desequenced
AsyncWriteJournal.Desequenced$
AsyncWriteJournal.Resequencer
AsyncWriteJournal$	INTERNAL API.
AsyncWriteProxy.SetStore
AsyncWriteProxy.SetStore$
AsyncWriteProxy$	INTERNAL API.
AsyncWriteTarget	INTERNAL API.
AsyncWriteTarget.DeleteMessages
AsyncWriteTarget.DeleteMessages$
AsyncWriteTarget.DeleteMessagesTo
AsyncWriteTarget.DeleteMessagesTo$
AsyncWriteTarget.ReadHighestSequenceNr
AsyncWriteTarget.ReadHighestSequenceNr$
AsyncWriteTarget.ReplayFailure
AsyncWriteTarget.ReplayFailure$
AsyncWriteTarget.ReplayMessages
AsyncWriteTarget.ReplayMessages$
AsyncWriteTarget.ReplaySuccess$
AsyncWriteTarget.WriteConfirmations
AsyncWriteTarget.WriteConfirmations$
AsyncWriteTarget.WriteMessages
AsyncWriteTarget.WriteMessages$
AsyncWriteTarget$	INTERNAL API.
JournalPerfSpec.BenchActor
JournalPerfSpec.Cmd
JournalPerfSpec.Cmd$
JournalPerfSpec.ResetCounter$
JournalPerfSpec$
JournalSpec.Confirmation
JournalSpec.Confirmation$
JournalSpec$
ReplayMediator

Exception Summary

AsyncReplayTimeoutException

Thrown if replay inactivity exceeds a specified timeout.