Search Java Classes and Packages
#Akka.persistence.journal Classes and Interfaces - 122 results found.
| Name | Description | Type | Package | Framework |
| 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 | |
| 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 | |
| EventSeq | Class | akka.persistence.journal | Akka | |
| EventSeq$ | Class | akka.persistence.journal | Akka | |
| EventsSeq | Class | akka.persistence.journal | Akka | |
| EventsSeq$ | Class | akka.persistence.journal | 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 | |
| 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 | |
| LeveldbRecovery | LevelDB backed message replay and sequence number recovery. | Interface | akka.persistence.journal.leveldb | Akka |
| LeveldbStore | Interface | akka.persistence.journal.leveldb | 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 | |
| ReadEventAdapter | Facility to convert from and to specialised data models, as may be required by specialized persistence Journals. | Interface | akka.persistence.journal | 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 | |
| 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 | |
| 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 | |
| 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 | |