Package akka.persistence.journal

Interface Summary

Interface	Description
AsyncRecovery	Asynchronous message replay and sequence number recovery interface.
AsyncReplay	A plugin may implement this trait as an optimization.
AsyncWriteJournal	Abstract journal, optimized for asynchronous, non-blocking writes.
AsyncWriteProxy	INTERNAL API.
EmptyEventSeq
EventAdapter	An EventAdapter is both a WriteEventAdapter and a ReadEventAdapter.
PersistencePluginProxy.PluginType
ReadEventAdapter	Facility to convert from and to specialised data models, as may be required by specialized persistence Journals.
WriteEventAdapter	Facility to convert to specialised data models, as may be required by specialized persistence Journals.
WriteJournalBase

Class Summary

Class	Description
AsyncWriteJournal.Desequenced
AsyncWriteJournal.Desequenced$
AsyncWriteJournal.Resequencer
AsyncWriteJournal$	INTERNAL API.
AsyncWriteProxy.InitTimeout$
AsyncWriteProxy.SetStore
AsyncWriteProxy.SetStore$
AsyncWriteProxy$	INTERNAL API.
AsyncWriteTarget	INTERNAL API.
AsyncWriteTarget.DeleteMessagesTo
AsyncWriteTarget.DeleteMessagesTo$
AsyncWriteTarget.ReplayFailure
AsyncWriteTarget.ReplayFailure$
AsyncWriteTarget.ReplayMessages
AsyncWriteTarget.ReplayMessages$
AsyncWriteTarget.ReplaySuccess
AsyncWriteTarget.ReplaySuccess$
AsyncWriteTarget.WriteMessages
AsyncWriteTarget.WriteMessages$
AsyncWriteTarget$	INTERNAL API.
EmptyEventSeq$
EventAdapters	EventAdapters serves as a per-journal collection of bound event adapters.
EventAdapters.CombinedReadEventAdapter$
EventAdapters$	INTERNAL API
EventSeq
EventSeq$
EventsSeq<E>
EventsSeq$
IdentityEventAdapter	No-op model adapter which passes through the incoming events as-is.
IdentityEventAdapter$	No-op model adapter which passes through the incoming events as-is.
IdentityEventAdapters
IdentityEventAdapters$
JournalPerfSpec	This spec measures execution times of the basic operations that an PersistentActor provides, using the provided Journal (plugin).
JournalPerfSpec.BenchActor
JournalPerfSpec.Cmd
JournalPerfSpec.Cmd$
JournalPerfSpec.ResetCounter$
JournalPerfSpec$
JournalSpec	This spec aims to verify custom akka-persistence Journal implementations.
JournalSpec$
NoopReadEventAdapter$
NoopWriteEventAdapter$
PersistencePluginProxy
PersistencePluginProxy.TargetLocation
PersistencePluginProxy.TargetLocation$
PersistencePluginProxy$
PersistencePluginProxyExtension
PersistencePluginProxyExtension$
PersistencePluginProxyExtensionImpl	PersistencePluginProxyExtensionImpl is an Extension that enables initialization of the PersistencePluginProxy via configuration, without requiring any code changes or the creation of any actors.
ReplayFilter$	INTERNAL API
ReplayMediator
SingleEventSeq
SingleEventSeq$
Tagged	The journal may support tagging of events that are used by the EventsByTag query and it may support specifying the tags via an EventAdapter that wraps the events in a Tagged with the given tags.
Tagged$

Exception Summary

Exception	Description
AsyncReplayTimeoutException	Thrown if replay inactivity exceeds a specified timeout.