Search Java Classes and Packages
#Akka.persistence Classes and Interfaces - 342 results found.
| Name | Description | Type | Package | Framework |
| AbstractEventsByPersistenceIdPublisher | Class | akka.persistence.query.journal.leveldb | Akka | |
| AbstractEventsByTagPublisher | Class | akka.persistence.query.journal.leveldb | Akka | |
| AbstractPersistentActor | Java API: an persistent actor - can be used to implement command or event sourcing. | Class | akka.persistence | Akka |
| AbstractPersistentActorWithAtLeastOnceDelivery | Java API compatible with lambda expressions Use this class instead of UntypedPersistentActor to send messages | Class | akka.persistence | Akka |
| AbstractPersistentFSM | Java API: compatible with lambda expressions Persistent Finite State Machine actor abstract base class. | Class | akka.persistence.fsm | Akka |
| AbstractPersistentFSMBase | Java API: compatible with lambda expressions Finite State Machine actor abstract base class. | Class | akka.persistence.fsm | Akka |
| AbstractPersistentFSMBase$ | Java API: compatible with lambda expressions This is an EXPERIMENTAL feature and is subject to change until it has received more real world testing. | Class | akka.persistence.fsm | Akka |
| AbstractPersistentLoggingFSM | Java API: compatible with lambda expressions Persistent Finite State Machine actor abstract base class with FSM Logging | Class | akka.persistence.fsm | Akka |
| AbstractPersistentView | Java API: compatible with lambda expressions (to be used with ReceiveBuilder)See Also:PersistentView | Class | akka.persistence | Akka |
| AllPersistenceIdsPublisher | Class | akka.persistence.query.journal.leveldb | Akka | |
| AllPersistenceIdsPublisher$ | Class | akka.persistence.query.journal.leveldb | Akka | |
| AllPersistenceIdsQuery | A plugin may optionally support this query by implementing this interface. | Interface | akka.persistence.query.javadsl | Akka |
| AllPersistenceIdsQuery | A plugin may optionally support this query by implementing this trait. | Interface | akka.persistence.query.scaladsl | Akka |
| AsyncRecovery | Asynchronous message replay and sequence number recovery interface. | Interface | akka.persistence.journal | Akka |
| AsyncRecovery | Java API: asynchronous message replay and sequence number recovery interface. | Class | akka.persistence.journal.japi | Akka |
| AsyncReplayTimeoutException | Thrown if replay inactivity exceeds a specified timeout. | Class | akka.persistence.journal | Akka |
| AsyncWriteJournal | Abstract journal, optimized for asynchronous, non-blocking writes. | Interface | akka.persistence.journal | Akka |
| AsyncWriteJournal | Java API: abstract journal, optimized for asynchronous, non-blocking writes. | Class | akka.persistence.journal.japi | Akka |
| AsyncWriteJournal$ | Class | akka.persistence.journal | Akka | |
| AsyncWriteJournal .Desequenced | Class | akka.persistence.journal.AsyncWriteJournal | Akka | |
| AsyncWriteJournal .Desequenced$ | Class | akka.persistence.journal.AsyncWriteJournal | Akka | |
| AsyncWriteJournal .Resequencer | Class | akka.persistence.journal.AsyncWriteJournal | Akka | |
| AsyncWriteProxy | A journal that delegates actual storage to a target actor. | Interface | akka.persistence.journal | Akka |
| AsyncWriteProxy$ | Class | akka.persistence.journal | Akka | |
| AsyncWriteProxy .InitTimeout$ | Class | akka.persistence.journal.AsyncWriteProxy | Akka | |
| AsyncWriteProxy .SetStore | Class | akka.persistence.journal.AsyncWriteProxy | Akka | |
| AsyncWriteProxy .SetStore$ | Class | akka.persistence.journal.AsyncWriteProxy | Akka | |
| AsyncWriteTarget | Class | akka.persistence.journal | Akka | |
| AsyncWriteTarget$ | Class | akka.persistence.journal | Akka | |
| AsyncWriteTarget .DeleteMessagesTo | Class | akka.persistence.journal.AsyncWriteTarget | Akka | |
| AsyncWriteTarget .DeleteMessagesTo$ | Class | akka.persistence.journal.AsyncWriteTarget | Akka | |
| AsyncWriteTarget .ReplayFailure | Class | akka.persistence.journal.AsyncWriteTarget | Akka | |
| AsyncWriteTarget .ReplayFailure$ | Class | akka.persistence.journal.AsyncWriteTarget | Akka | |
| AsyncWriteTarget .ReplayMessages | Class | akka.persistence.journal.AsyncWriteTarget | Akka | |
| AsyncWriteTarget .ReplayMessages$ | Class | akka.persistence.journal.AsyncWriteTarget | Akka | |
| AsyncWriteTarget .ReplaySuccess | Class | akka.persistence.journal.AsyncWriteTarget | Akka | |
| AsyncWriteTarget .ReplaySuccess$ | Class | akka.persistence.journal.AsyncWriteTarget | Akka | |
| AsyncWriteTarget .WriteMessages | Class | akka.persistence.journal.AsyncWriteTarget | Akka | |
| AsyncWriteTarget .WriteMessages$ | Class | akka.persistence.journal.AsyncWriteTarget | Akka | |
| AtLeastOnceDelivery | Mix-in this trait with your PersistentActor to send messages with at-least-once delivery semantics to destinations. | Interface | akka.persistence | Akka |
| AtLeastOnceDelivery$ | Class | akka.persistence | Akka | |
| AtLeastOnceDelivery .AtLeastOnceDeliverySnapshot | Snapshot of current AtLeastOnceDelivery state. | Class | akka.persistence.AtLeastOnceDelivery | Akka |
| AtLeastOnceDelivery .AtLeastOnceDeliverySnapshot$ | Class | akka.persistence.AtLeastOnceDelivery | Akka | |
| AtLeastOnceDelivery .Internal$ | Class | akka.persistence.AtLeastOnceDelivery | Akka | |
| AtLeastOnceDelivery .MaxUnconfirmedMessagesExceededException | See Also:AtLeastOnceDeliveryLike. | Class | akka.persistence.AtLeastOnceDelivery | Akka |
| AtLeastOnceDelivery .UnconfirmedDelivery | Information about a message that has not been confirmed. | Class | akka.persistence.AtLeastOnceDelivery | Akka |
| AtLeastOnceDelivery .UnconfirmedDelivery$ | Class | akka.persistence.AtLeastOnceDelivery | Akka | |
| AtLeastOnceDelivery .UnconfirmedWarning | See Also:AtLeastOnceDeliveryLike. | Class | akka.persistence.AtLeastOnceDelivery | Akka |
| AtLeastOnceDelivery .UnconfirmedWarning$ | Class | akka.persistence.AtLeastOnceDelivery | Akka | |
| AtLeastOnceDeliveryLike | Interface | akka.persistence | Akka | |
| AtomicWrite | Class | akka.persistence | Akka | |
| AtomicWrite$ | Class | akka.persistence | Akka | |
| CapabilityFlag | Class | akka.persistence | Akka | |
| CapabilityFlag$ | Class | akka.persistence | Akka | |
| CurrentEventsByPersistenceIdPublisher | Class | akka.persistence.query.journal.leveldb | Akka | |
| CurrentEventsByPersistenceIdQuery | A plugin may optionally support this query by implementing this interface. | Interface | akka.persistence.query.javadsl | Akka |
| CurrentEventsByPersistenceIdQuery | A plugin may optionally support this query by implementing this trait. | Interface | akka.persistence.query.scaladsl | Akka |
| CurrentEventsByTagPublisher | Class | akka.persistence.query.journal.leveldb | Akka | |
| CurrentEventsByTagQuery | A plugin may optionally support this query by implementing this interface. | Interface | akka.persistence.query.javadsl | Akka |
| CurrentEventsByTagQuery | A plugin may optionally support this query by implementing this trait. | Interface | akka.persistence.query.scaladsl | Akka |
| CurrentPersistenceIdsQuery | A plugin may optionally support this query by implementing this interface. | Interface | akka.persistence.query.javadsl | Akka |
| CurrentPersistenceIdsQuery | A plugin may optionally support this query by implementing this trait. | Interface | akka.persistence.query.scaladsl | Akka |
| DeleteMessagesFailure | Reply message to a failed Eventsourced. | Class | akka.persistence | Akka |
| DeleteMessagesFailure$ | Class | akka.persistence | Akka | |
| DeleteMessagesSuccess | Reply message to a successful Eventsourced. | Class | akka.persistence | Akka |
| DeleteMessagesSuccess$ | Class | akka.persistence | Akka | |
| DeleteSnapshotFailure | Sent to a PersistentActor after failed deletion of a snapshot. | Class | akka.persistence | Akka |
| DeleteSnapshotFailure$ | Class | akka.persistence | Akka | |
| DeleteSnapshotsFailure | Sent to a PersistentActor after failed deletion of a range of snapshots. | Class | akka.persistence | Akka |
| DeleteSnapshotsFailure$ | Class | akka.persistence | Akka | |
| DeleteSnapshotsSuccess | Sent to a PersistentActor after successful deletion of specified range of snapshots. | Class | akka.persistence | Akka |
| DeleteSnapshotsSuccess$ | Class | akka.persistence | Akka | |
| DeleteSnapshotSuccess | Sent to a PersistentActor after successful deletion of a snapshot. | Class | akka.persistence | Akka |
| DeleteSnapshotSuccess$ | Class | akka.persistence | Akka | |
| DeliveryBuffer | scala. | Interface | akka.persistence.query.journal.leveldb | Akka |
| EmptyEventSeq$ | Class | akka.persistence.journal | Akka | |
| EventAdapter | An EventAdapter is both a WriteEventAdapter and a ReadEventAdapter. | Interface | akka.persistence.journal | Akka |
| EventAdapters | EventAdapters serves as a per-journal collection of bound event adapters. | Class | akka.persistence.journal | Akka |
| EventAdapters$ | Class | akka.persistence.journal | Akka | |
| EventAdapters .CombinedReadEventAdapter | Class | akka.persistence.journal.EventAdapters | Akka | |
| EventAdapters .CombinedReadEventAdapter$ | Class | akka.persistence.journal.EventAdapters | Akka | |
| EventEnvelope | Event wrapper adding meta data for the events in the result stream of EventsByTagQuery query, or similar queries. | Class | akka.persistence.query | Akka |
| EventEnvelope$ | Class | akka.persistence.query | Akka | |
| EventsByPersistenceIdPublisher | Class | akka.persistence.query.journal.leveldb | Akka | |
| EventsByPersistenceIdPublisher$ | Class | akka.persistence.query.journal.leveldb | Akka | |
| EventsByPersistenceIdPublisher .Continue$ | Class | akka.persistence.query.journal.leveldb.EventsByPersistenceIdPublisher | Akka | |
| EventsByPersistenceIdQuery | A plugin may optionally support this query by implementing this interface. | Interface | akka.persistence.query.javadsl | Akka |
| EventsByPersistenceIdQuery | A plugin may optionally support this query by implementing this trait. | Interface | akka.persistence.query.scaladsl | Akka |
| EventsByTagPublisher | Class | akka.persistence.query.journal.leveldb | Akka | |
| EventsByTagPublisher$ | Class | akka.persistence.query.journal.leveldb | Akka | |
| EventsByTagPublisher .Continue$ | Class | akka.persistence.query.journal.leveldb.EventsByTagPublisher | Akka | |
| EventsByTagQuery | A plugin may optionally support this query by implementing this interface. | Interface | akka.persistence.query.javadsl | Akka |
| EventsByTagQuery | A plugin may optionally support this query by implementing this trait. | Interface | akka.persistence.query.scaladsl | Akka |
| EventSeq | Class | akka.persistence.journal | Akka | |
| EventSeq$ | Class | akka.persistence.journal | Akka | |
| Eventsourced | Scala API and implementation details of PersistentActor, AbstractPersistentActor and UntypedPersistentActor. | Interface | akka.persistence | Akka |
| Eventsourced$ | Class | akka.persistence | Akka | |
| Eventsourced .AsyncHandlerInvocation | does not force the actor to stash commands; Originates from either `persistAsync` or `defer` callsSee Also:Serialized Form | Class | akka.persistence.Eventsourced | Akka |
| Eventsourced .AsyncHandlerInvocation$ | Class | akka.persistence.Eventsourced | Akka | |
| Eventsourced .PendingHandlerInvocation | java. | Interface | akka.persistence.Eventsourced | Akka |
| Eventsourced .ProcessingState | Class | akka.persistence.Eventsourced | Akka | |
| Eventsourced .StashingHandlerInvocation | forces actor to stash incoming commands until all these invocations are handledSee Also:Serialized Form | Class | akka.persistence.Eventsourced | Akka |
| Eventsourced .StashingHandlerInvocation$ | Class | akka.persistence.Eventsourced | Akka | |
| Eventsourced .State | java. | Interface | akka.persistence.Eventsourced | Akka |
| EventsSeq | Class | akka.persistence.journal | Akka | |
| EventsSeq$ | Class | akka.persistence.journal | Akka | |
| FSMStateFunctionBuilder | Builder used to create a partial function for FSM. | Class | akka.persistence.fsm.japi.pf | Akka |
| FSMStopBuilder | Builder used to create a partial function for FSM. | Class | akka.persistence.fsm.japi.pf | Akka |
| IdentityEventAdapter | No-op model adapter which passes through the incoming events as-is. | Class | akka.persistence.journal | Akka |
| IdentityEventAdapter$ | No-op model adapter which passes through the incoming events as-is. | Class | akka.persistence.journal | Akka |
| IdentityEventAdapters | Class | akka.persistence.journal | Akka | |
| IdentityEventAdapters$ | Class | akka.persistence.journal | Akka | |
| InmemJournal | In-memory journal for testing purposes only. | Class | akka.persistence.journal.inmem | Akka |
| InmemMessages | Interface | akka.persistence.journal.inmem | Akka | |
| InmemStore | Class | akka.persistence.journal.inmem | Akka | |
| JavaJournalPerfSpec | Java / JUnit consumable equivalent of JournalPerfSpec and JournalSpec. | Class | akka.persistence.japi.journal | Akka |
| JavaJournalSpec | Java / JUnit API for JournalSpec. | Class | akka.persistence.japi.journal | Akka |
| JavaSnapshotStoreSpec | This spec aims to verify custom akka-persistence SnapshotStore implementations. | Class | akka.persistence.japi.snapshot | Akka |
| JournalCapabilityFlags | When true enables tests which check if the Journal properly rejects writes of objects which are not java. | Interface | akka.persistence | Akka |
| JournalPerfSpec | This spec measures execution times of the basic operations that an PersistentActor provides, using the provided Journal (plugin). | Class | akka.persistence.journal | Akka |
| JournalPerfSpec$ | Class | akka.persistence.journal | Akka | |
| JournalPerfSpec .BenchActor | Class | akka.persistence.journal.JournalPerfSpec | Akka | |
| JournalPerfSpec .Cmd | Class | akka.persistence.journal.JournalPerfSpec | Akka | |
| JournalPerfSpec .Cmd$ | Class | akka.persistence.journal.JournalPerfSpec | Akka | |
| JournalPerfSpec .ResetCounter$ | Class | akka.persistence.journal.JournalPerfSpec | Akka | |
| JournalProtocol | Messages exchanged between persistent actors, views and a journal. | Class | akka.persistence | Akka |
| JournalProtocol$ | Messages exchanged between persistent actors, views and a journal. | Class | akka.persistence | Akka |
| JournalProtocol .DeleteMessagesTo | Request to delete all persistent messages with sequence numbers up to toSequenceNrSee Also:Serialized Form | Class | akka.persistence.JournalProtocol | Akka |
| JournalProtocol .DeleteMessagesTo$ | Class | akka.persistence.JournalProtocol | Akka | |
| JournalProtocol .LoopMessageSuccess | Reply message to a JournalProtocol. | Class | akka.persistence.JournalProtocol | Akka |
| JournalProtocol .LoopMessageSuccess$ | Class | akka.persistence.JournalProtocol | Akka | |
| JournalProtocol .RecoverySuccess | Reply message to a successful JournalProtocol. | Class | akka.persistence.JournalProtocol | Akka |
| JournalProtocol .RecoverySuccess$ | Class | akka.persistence.JournalProtocol | Akka | |
| JournalProtocol .ReplayedMessage | Reply message to a JournalProtocol. | Class | akka.persistence.JournalProtocol | Akka |
| JournalProtocol .ReplayedMessage$ | Class | akka.persistence.JournalProtocol | Akka | |
| JournalProtocol .ReplayMessages | Request to replay messages to persistentActor. | Class | akka.persistence.JournalProtocol | Akka |
| JournalProtocol .ReplayMessages$ | Class | akka.persistence.JournalProtocol | Akka | |
| JournalProtocol .ReplayMessagesFailure | Reply message to a failed JournalProtocol. | Class | akka.persistence.JournalProtocol | Akka |
| JournalProtocol .ReplayMessagesFailure$ | Class | akka.persistence.JournalProtocol | Akka | |
| JournalProtocol .WriteMessageFailure | Reply message to a failed JournalProtocol. | Class | akka.persistence.JournalProtocol | Akka |
| JournalProtocol .WriteMessageFailure$ | Class | akka.persistence.JournalProtocol | Akka | |
| JournalProtocol .WriteMessageRejected | Reply message to a rejected JournalProtocol. | Class | akka.persistence.JournalProtocol | Akka |
| JournalProtocol .WriteMessageRejected$ | Class | akka.persistence.JournalProtocol | Akka | |
| JournalProtocol .WriteMessages | Request to write messages. | Class | akka.persistence.JournalProtocol | Akka |
| JournalProtocol .WriteMessages$ | Class | akka.persistence.JournalProtocol | Akka | |
| JournalProtocol .WriteMessagesFailed | Reply message to a failed JournalProtocol. | Class | akka.persistence.JournalProtocol | Akka |
| JournalProtocol .WriteMessagesFailed$ | Class | akka.persistence.JournalProtocol | Akka | |
| JournalProtocol .WriteMessagesSuccessful$ | Reply message to a successful JournalProtocol. | Class | akka.persistence.JournalProtocol | Akka |
| JournalProtocol .WriteMessageSuccess | Reply message to a successful JournalProtocol. | Class | akka.persistence.JournalProtocol | Akka |
| JournalProtocol .WriteMessageSuccess$ | Class | akka.persistence.JournalProtocol | Akka | |
| JournalSpec | This spec aims to verify custom akka-persistence Journal implementations. | Class | akka.persistence.journal | Akka |
| JournalSpec$ | Class | akka.persistence.journal | Akka | |
| Key | Class | akka.persistence.journal.leveldb | Akka | |
| Key$ | Class | akka.persistence.journal.leveldb | Akka | |
| LeveldbIdMapping | LevelDB backed persistent mapping of String-based persistent actor ids to numeric ids. | Interface | akka.persistence.journal.leveldb | Akka |
| LeveldbJournal | Journal backed by a local LevelDB store. | Class | akka.persistence.journal.leveldb | Akka |
| LeveldbJournal$ | Class | akka.persistence.journal.leveldb | Akka | |
| LeveldbJournal .CurrentPersistenceIds | Class | akka.persistence.journal.leveldb.LeveldbJournal | Akka | |
| LeveldbJournal .CurrentPersistenceIds$ | Class | akka.persistence.journal.leveldb.LeveldbJournal | Akka | |
| LeveldbJournal .EventAppended | Class | akka.persistence.journal.leveldb.LeveldbJournal | Akka | |
| LeveldbJournal .EventAppended$ | Class | akka.persistence.journal.leveldb.LeveldbJournal | Akka | |
| LeveldbJournal .PersistenceIdAdded | Class | akka.persistence.journal.leveldb.LeveldbJournal | Akka | |
| LeveldbJournal .PersistenceIdAdded$ | Class | akka.persistence.journal.leveldb.LeveldbJournal | Akka | |
| LeveldbJournal .ReplayedTaggedMessage | Class | akka.persistence.journal.leveldb.LeveldbJournal | Akka | |
| LeveldbJournal .ReplayedTaggedMessage$ | Class | akka.persistence.journal.leveldb.LeveldbJournal | Akka | |
| LeveldbJournal .ReplayTaggedMessages | Class | akka.persistence.journal.leveldb.LeveldbJournal | Akka | |
| LeveldbJournal .ReplayTaggedMessages$ | Class | akka.persistence.journal.leveldb.LeveldbJournal | Akka | |
| LeveldbJournal .SubscribeAllPersistenceIds$ | Subscribe the sender to current and new persistenceIds. | Class | akka.persistence.journal.leveldb.LeveldbJournal | Akka |
| LeveldbJournal .SubscribePersistenceId | Subscribe the sender to changes (appended events) for a specific persistenceId. | Class | akka.persistence.journal.leveldb.LeveldbJournal | Akka |
| LeveldbJournal .SubscribePersistenceId$ | Class | akka.persistence.journal.leveldb.LeveldbJournal | Akka | |
| LeveldbJournal .SubscribeTag | Subscribe the sender to changes (appended events) for a specific tag. | Class | akka.persistence.journal.leveldb.LeveldbJournal | Akka |
| LeveldbJournal .SubscribeTag$ | Class | akka.persistence.journal.leveldb.LeveldbJournal | Akka | |
| LeveldbJournal .TaggedEventAppended | Class | akka.persistence.journal.leveldb.LeveldbJournal | Akka | |
| LeveldbJournal .TaggedEventAppended$ | Class | akka.persistence.journal.leveldb.LeveldbJournal | Akka | |
| LeveldbReadJournal | Java API: ReadJournal implementation for LevelDB. | Class | akka.persistence.query.journal.leveldb.javadsl | Akka |
| LeveldbReadJournal | Scala API ReadJournal implementation for LevelDB. | Class | akka.persistence.query.journal.leveldb.scaladsl | Akka |
| LeveldbReadJournal$ | Class | akka.persistence.query.journal.leveldb.javadsl | Akka | |
| LeveldbReadJournal$ | Class | akka.persistence.query.journal.leveldb.scaladsl | Akka | |
| LeveldbReadJournalProvider | Class | akka.persistence.query.journal.leveldb | Akka | |
| LeveldbRecovery | LevelDB backed message replay and sequence number recovery. | Interface | akka.persistence.journal.leveldb | Akka |
| LeveldbStore | Interface | akka.persistence.journal.leveldb | Akka | |
| LiveEventsByPersistenceIdPublisher | Class | akka.persistence.query.journal.leveldb | Akka | |
| LiveEventsByTagPublisher | Class | akka.persistence.query.journal.leveldb | Akka | |
| LocalSnapshotStore | Local filesystem backed snapshot store. | Class | akka.persistence.snapshot.local | Akka |
| LoggingPersistentFSM | Stackable trait for FSM which adds a rolling event log and debug logging capabilities (analogous to LoggingReceive). | Interface | akka.persistence.fsm | Akka |
| MayVerb | Interface | akka.persistence.scalatest | Akka | |
| MayVerb$ | Class | akka.persistence.scalatest | Akka | |
| MayVerb .StringMayWrapperForVerb | org. | Interface | akka.persistence.scalatest.MayVerb | Akka |
| MayVerb .TestCanceledByFailure | Class | akka.persistence.scalatest.MayVerb | Akka | |
| MayVerb .TestCanceledByFailure$ | Class | akka.persistence.scalatest.MayVerb | Akka | |
| MessageFormats | Class | akka.persistence.serialization | Akka | |
| MessageFormats .AtLeastOnceDeliverySnapshot | Protobuf type AtLeastOnceDeliverySnapshotSee Also:Serialized Form | Class | akka.persistence.serialization.MessageFormats | Akka |
| MessageFormats .AtLeastOnceDeliverySnapshot .Builder | Protobuf type AtLeastOnceDeliverySnapshot | Class | akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot | Akka |
| MessageFormats .AtLeastOnceDeliverySnapshot .UnconfirmedDelivery | Protobuf type AtLeastOnceDeliverySnapshot. | Class | akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot | Akka |
| MessageFormats .AtLeastOnceDeliverySnapshot .UnconfirmedDelivery .Builder | Protobuf type AtLeastOnceDeliverySnapshot. | Class | akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery | Akka |
| MessageFormats .AtLeastOnceDeliverySnapshot .UnconfirmedDeliveryOrBuilder | required int64 deliveryId = 1;java. | Interface | akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot | Akka |
| MessageFormats .AtLeastOnceDeliverySnapshotOrBuilder | required int64 currentDeliveryId = 1;MessageFormats. | Interface | akka.persistence.serialization.MessageFormats | Akka |
| MessageFormats .AtomicWrite | Protobuf type AtomicWriteSee Also:Serialized Form | Class | akka.persistence.serialization.MessageFormats | Akka |
| MessageFormats .AtomicWrite .Builder | Protobuf type AtomicWriterepeated . | Class | akka.persistence.serialization.MessageFormats.AtomicWrite | Akka |
| MessageFormats .AtomicWriteOrBuilder | repeated . | Interface | akka.persistence.serialization.MessageFormats | Akka |
| MessageFormats .PersistentMessage | Protobuf type PersistentMessageSee Also:Serialized Form | Class | akka.persistence.serialization.MessageFormats | Akka |
| MessageFormats .PersistentMessage .Builder | Protobuf type PersistentMessageConstructs the message based on the state of the Builder. | Class | akka.persistence.serialization.MessageFormats.PersistentMessage | Akka |
| MessageFormats .PersistentMessageOrBuilder | optional bool deleted = 4; not used in new records from 2. | Interface | akka.persistence.serialization.MessageFormats | Akka |
| MessageFormats .PersistentPayload | Protobuf type PersistentPayloadSee Also:Serialized Form | Class | akka.persistence.serialization.MessageFormats | Akka |
| MessageFormats .PersistentPayload .Builder | Protobuf type PersistentPayloadConstructs the message based on the state of the Builder. | Class | akka.persistence.serialization.MessageFormats.PersistentPayload | Akka |
| MessageFormats .PersistentPayloadOrBuilder | required bytes payload = 2;ByteStringgetPayloadManifest() | Interface | akka.persistence.serialization.MessageFormats | Akka |
| MessageFormats .PersistentStateChangeEvent | Protobuf type PersistentStateChangeEventSee Also:Serialized Form | Class | akka.persistence.serialization.MessageFormats | Akka |
| MessageFormats .PersistentStateChangeEvent .Builder | Protobuf type PersistentStateChangeEventConstructs the message based on the state of the Builder. | Class | akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent | Akka |
| MessageFormats .PersistentStateChangeEventOrBuilder | required string stateIdentifier = 1;ByteStringgetStateIdentifierBytes() | Interface | akka.persistence.serialization.MessageFormats | Akka |
| MessageSerializer | Protobuf serializer for PersistentRepr, AtLeastOnceDelivery and PersistentFSM. | Class | akka.persistence.serialization | Akka |
| NonPersistentRepr | Message which can be resequenced by the Journal, but will not be persisted. | Class | akka.persistence | Akka |
| NonPersistentRepr$ | Class | akka.persistence | Akka | |
| NoopReadEventAdapter | Class | akka.persistence.journal | Akka | |
| NoopReadEventAdapter$ | Class | akka.persistence.journal | Akka | |
| NoopWriteEventAdapter | Class | akka.persistence.journal | Akka | |
| NoopWriteEventAdapter$ | Class | akka.persistence.journal | Akka | |
| NoSnapshotStore | Used as default snapshot-store in case no other store was configured. | Class | akka.persistence.snapshot | Akka |
| OptionalTests | scala. | Interface | akka.persistence.scalatest | Akka |
| Persistence | Persistence extension. | Class | akka.persistence | Akka |
| Persistence$ | Persistence extension provider. | Class | akka.persistence | Akka |
| Persistence .PluginHolder | Class | akka.persistence.Persistence | Akka | |
| Persistence .PluginHolder$ | Class | akka.persistence.Persistence | Akka | |
| PersistenceIdentity | Identification of PersistentActor or PersistentView. | Interface | akka.persistence | Akka |
| PersistenceQuery | Class | akka.persistence.query | Akka | |
| PersistenceQuery$ | Persistence extension for queries. | Class | akka.persistence.query | Akka |
| PersistenceQuery .PluginHolder | Class | akka.persistence.query.PersistenceQuery | Akka | |
| PersistenceQuery .PluginHolder$ | Class | akka.persistence.query.PersistenceQuery | Akka | |
| PersistenceRecovery | Called when the persistent actor is started for the first time. | Interface | akka.persistence | Akka |
| PersistenceSettings | Persistence configuration. | Class | akka.persistence | Akka |
| PersistentActor | An persistent Actor - can be used to implement command or event sourcing. | Interface | akka.persistence | Akka |
| PersistentEnvelope | Marks messages which can be resequenced by the AsyncWriteJournal. | Interface | akka.persistence | Akka |
| PersistentFSM | A FSM implementation with persistent state. | Interface | akka.persistence.fsm | Akka |
| PersistentFSM$ | Class | akka.persistence.fsm | Akka | |
| PersistentFSM .$minus$greater$ | This extractor is just convenience for matching a (S, S) pair, including a reminder what the new state is. | Class | akka.persistence.fsm.PersistentFSM | Akka |
| PersistentFSM .CurrentState | Message type which is sent directly to the subscribed actor in FSM. | Class | akka.persistence.fsm.PersistentFSM | Akka |
| PersistentFSM .CurrentState$ | Class | akka.persistence.fsm.PersistentFSM | Akka | |
| PersistentFSM .Event | All messages sent to the FSM will be wrapped inside an Event, which allows pattern matching to extract both state and data. | Class | akka.persistence.fsm.PersistentFSM | Akka |
| PersistentFSM .Event$ | Class | akka.persistence.fsm.PersistentFSM | Akka | |
| PersistentFSM .Failure | Signifies that the FSM is shutting itself down because of an error, e. | Class | akka.persistence.fsm.PersistentFSM | Akka |
| PersistentFSM .Failure$ | Class | akka.persistence.fsm.PersistentFSM | Akka | |
| PersistentFSM .FSMState | FSMState base trait, makes possible for simple default serialization by conversion to Stringjava. | Interface | akka.persistence.fsm.PersistentFSM | Akka |
| PersistentFSM .LogEntry | Log Entry of the LoggingFSM, can be obtained by calling getLog. | Class | akka.persistence.fsm.PersistentFSM | Akka |
| PersistentFSM .LogEntry$ | Class | akka.persistence.fsm.PersistentFSM | Akka | |
| PersistentFSM .Normal$ | Default reason if calling stop(). | Class | akka.persistence.fsm.PersistentFSM | Akka |
| PersistentFSM .NullFunction$ | A partial function value which does not match anything and can be used to “reset” whenUnhandled and onTermination handlers. | Class | akka.persistence.fsm.PersistentFSM | Akka |
| PersistentFSM .Shutdown$ | Reason given when someone was calling system. | Class | akka.persistence.fsm.PersistentFSM | Akka |
| PersistentFSM .State | This captures all of the managed state of the FSM: the state name, the state data, possibly custom timeout, stop reason, replies | Class | akka.persistence.fsm.PersistentFSM | Akka |
| PersistentFSM .State$ | Class | akka.persistence.fsm.PersistentFSM | Akka | |
| PersistentFSM .StateChangeEvent | Persisted on state change param: stateIdentifier FSM state identifier | Class | akka.persistence.fsm.PersistentFSM | Akka |
| PersistentFSM .StateChangeEvent$ | Class | akka.persistence.fsm.PersistentFSM | Akka | |
| PersistentFSM .StateTimeout$ | This case object is received in case of a state timeout. | Class | akka.persistence.fsm.PersistentFSM | Akka |
| PersistentFSM .StopEvent | Case class representing the state of the FSM whithin the onTermination block. | Class | akka.persistence.fsm.PersistentFSM | Akka |
| PersistentFSM .StopEvent$ | Class | akka.persistence.fsm.PersistentFSM | Akka | |
| PersistentFSM .SubscribeTransitionCallBack | Send this to an FSM to request first the PersistentFSM. | Class | akka.persistence.fsm.PersistentFSM | Akka |
| PersistentFSM .SubscribeTransitionCallBack$ | Class | akka.persistence.fsm.PersistentFSM | Akka | |
| PersistentFSM .TimeoutMarker | Class | akka.persistence.fsm.PersistentFSM | Akka | |
| PersistentFSM .TimeoutMarker$ | Class | akka.persistence.fsm.PersistentFSM | Akka | |
| PersistentFSM .Timer | Class | akka.persistence.fsm.PersistentFSM | Akka | |
| PersistentFSM .Timer$ | Class | akka.persistence.fsm.PersistentFSM | Akka | |
| PersistentFSM .Transition | Message type which is used to communicate transitions between states to all subscribed listeners (use FSM. | Class | akka.persistence.fsm.PersistentFSM | Akka |
| PersistentFSM .Transition$ | Class | akka.persistence.fsm.PersistentFSM | Akka | |
| PersistentFSM .UnsubscribeTransitionCallBack | Unsubscribe from FSM. | Class | akka.persistence.fsm.PersistentFSM | Akka |
| PersistentFSM .UnsubscribeTransitionCallBack$ | Class | akka.persistence.fsm.PersistentFSM | Akka | |
| PersistentFSMBase | Finite State Machine actor trait. | Interface | akka.persistence.fsm | Akka |
| PersistentFSMBase .TransformHelper | Class | akka.persistence.fsm.PersistentFSMBase | Akka | |
| PersistentImpl | Class | akka.persistence | Akka | |
| PersistentImpl$ | Class | akka.persistence | Akka | |
| PersistentRepr | Plugin API: representation of a persistent message in the journal plugin API. | Interface | akka.persistence | Akka |
| PersistentRepr$ | Class | akka.persistence | Akka | |
| PersistentView | A view replicates the persistent message stream of a PersistentActor. | Interface | akka.persistence | Akka |
| PersistentView$ | Class | akka.persistence | Akka | |
| PersistentView .ScheduledUpdate | Class | akka.persistence.PersistentView | Akka | |
| PersistentView .ScheduledUpdate$ | Class | akka.persistence.PersistentView | Akka | |
| PersistentView .State | java. | Interface | akka.persistence.PersistentView | Akka |
| PluginSpec | Class | akka.persistence | Akka | |
| Protocol | Messages exchanged between persistent actors, views and a journal/snapshot-store. | Class | akka.persistence | Akka |
| Protocol$ | Messages exchanged between persistent actors, views and a journal/snapshot-store. | Class | akka.persistence | Akka |
| Protocol .Message | Internal persistence extension messages extend this trait. | Interface | akka.persistence.Protocol | Akka |
| ReadEventAdapter | Facility to convert from and to specialised data models, as may be required by specialized persistence Journals. | Interface | akka.persistence.journal | Akka |
| ReadJournal | API for reading persistent events and information derived from stored persistent events. | Interface | akka.persistence.query.javadsl | Akka |
| ReadJournal | API for reading persistent events and information derived from stored persistent events. | Interface | akka.persistence.query.scaladsl | Akka |
| ReadJournalProvider | A query plugin must implement a class that implements this trait. | Interface | akka.persistence.query | Akka |
| Recovery | Recovery mode configuration object to be returned in PersistenceRecovery. | Class | akka.persistence | Akka |
| Recovery$ | Class | akka.persistence | Akka | |
| RecoveryCompleted | Class | akka.persistence | Akka | |
| RecoveryCompleted$ | Sent to a PersistentActor when the journal replay has been finished. | Class | akka.persistence | Akka |
| ReplayFilter | Class | akka.persistence.journal | Akka | |
| ReplayFilter$ | Detect corrupt event stream during replay. | Class | akka.persistence.journal | Akka |
| ReplayFilter .Disabled$ | Class | akka.persistence.journal.ReplayFilter | Akka | |
| ReplayFilter .Fail$ | Class | akka.persistence.journal.ReplayFilter | Akka | |
| ReplayFilter .RepairByDiscardOld$ | Class | akka.persistence.journal.ReplayFilter | Akka | |
| ReplayFilter .Warn$ | Class | akka.persistence.journal.ReplayFilter | Akka | |
| ReplayMediator | Class | akka.persistence.journal | Akka | |
| SaveSnapshotFailure | Sent to a PersistentActor after failed saving of a snapshot. | Class | akka.persistence | Akka |
| SaveSnapshotFailure$ | Class | akka.persistence | Akka | |
| SaveSnapshotSuccess | Sent to a PersistentActor after successful saving of a snapshot. | Class | akka.persistence | Akka |
| SaveSnapshotSuccess$ | Class | akka.persistence | Akka | |
| SelectedSnapshot | Plugin API: a selected snapshot matching SnapshotSelectionCriteria. | Class | akka.persistence | Akka |
| SelectedSnapshot$ | Class | akka.persistence | Akka | |
| SharedLeveldbJournal | Journal backed by a SharedLeveldbStore. | Class | akka.persistence.journal.leveldb | Akka |
| SharedLeveldbJournal$ | Class | akka.persistence.journal.leveldb | Akka | |
| SharedLeveldbStore | A LevelDB store that can be shared by multiple actor systems. | Class | akka.persistence.journal.leveldb | Akka |
| SingleEventSeq | Class | akka.persistence.journal | Akka | |
| SingleEventSeq$ | Class | akka.persistence.journal | Akka | |
| Snapshot | Wrapper for snapshot data. | Class | akka.persistence.serialization | Akka |
| Snapshot$ | Class | akka.persistence.serialization | Akka | |
| SnapshotHeader | Class | akka.persistence.serialization | Akka | |
| SnapshotHeader$ | Class | akka.persistence.serialization | Akka | |
| SnapshotMetadata | param: persistenceId id of persistent actor from which the snapshot was taken. | Class | akka.persistence | Akka |
| SnapshotMetadata$ | Class | akka.persistence | Akka | |
| SnapshotOffer | Offers a PersistentActor a previously saved snapshot during recovery. | Class | akka.persistence | Akka |
| SnapshotOffer$ | Class | akka.persistence | Akka | |
| SnapshotProtocol | Defines messages exchanged between persistent actors and a snapshot store. | Class | akka.persistence | Akka |
| SnapshotProtocol$ | Defines messages exchanged between persistent actors and a snapshot store. | Class | akka.persistence | Akka |
| SnapshotProtocol .DeleteSnapshot | Instructs snapshot store to delete a snapshot. | Class | akka.persistence.SnapshotProtocol | Akka |
| SnapshotProtocol .DeleteSnapshot$ | Class | akka.persistence.SnapshotProtocol | Akka | |
| SnapshotProtocol .DeleteSnapshots | Instructs snapshot store to delete all snapshots that match criteria. | Class | akka.persistence.SnapshotProtocol | Akka |
| SnapshotProtocol .DeleteSnapshots$ | Class | akka.persistence.SnapshotProtocol | Akka | |
| SnapshotProtocol .LoadSnapshot | Instructs a snapshot store to load a snapshot. | Class | akka.persistence.SnapshotProtocol | Akka |
| SnapshotProtocol .LoadSnapshot$ | Class | akka.persistence.SnapshotProtocol | Akka | |
| SnapshotProtocol .LoadSnapshotResult | Response message to a SnapshotProtocol. | Class | akka.persistence.SnapshotProtocol | Akka |
| SnapshotProtocol .LoadSnapshotResult$ | Class | akka.persistence.SnapshotProtocol | Akka | |
| SnapshotProtocol .SaveSnapshot | Instructs snapshot store to save a snapshot. | Class | akka.persistence.SnapshotProtocol | Akka |
| SnapshotProtocol .SaveSnapshot$ | Class | akka.persistence.SnapshotProtocol | Akka | |
| SnapshotSelectionCriteria | Selection criteria for loading and deleting snapshots. | Class | akka.persistence | Akka |
| SnapshotSelectionCriteria$ | Class | akka.persistence | Akka | |
| SnapshotSerializer | Snapshot serializer. | Class | akka.persistence.serialization | Akka |
| SnapshotSerializer$ | Class | akka.persistence.serialization | Akka | |
| SnapshotStore | Java API: abstract snapshot store. | Class | akka.persistence.snapshot.japi | Akka |
| SnapshotStore | Abstract snapshot store. | Interface | akka.persistence.snapshot | Akka |
| SnapshotStoreSpec | This spec aims to verify custom akka-persistence SnapshotStore implementations. | Class | akka.persistence.snapshot | Akka |
| SnapshotStoreSpec$ | Class | akka.persistence.snapshot | Akka | |
| Snapshotter | Snapshot API on top of the internal snapshot protocol. | Interface | akka.persistence | Akka |
| Tagged | The journal may support tagging of events that are used by the EventsByTag query and it may support specifying the tags via an | Class | akka.persistence.journal | Akka |
| Tagged$ | Class | akka.persistence.journal | Akka | |
| UntypedPersistentActor | Java API: an persistent actor - can be used to implement command or event sourcing. | Class | akka.persistence | Akka |
| UntypedPersistentActorWithAtLeastOnceDelivery | Java API: Use this class instead of UntypedPersistentActor to send messages with at-least-once delivery semantics to destinations. | Class | akka.persistence | Akka |
| UntypedPersistentView | Class | akka.persistence | Akka | |
| Update | Instructs a PersistentView to update itself. | Class | akka.persistence | Akka |
| Update$ | Class | akka.persistence | Akka | |
| WriteEventAdapter | Facility to convert to specialised data models, as may be required by specialized persistence Journals. | Interface | akka.persistence.journal | Akka |
| WriteJournalBase | Interface | akka.persistence.journal | Akka | |