Search Java Classes and Packages

Search Java Frameworks and Libraries

255581 classes and counting ...
Search Tips Index Status



#Akka.persistence.journal Classes and Interfaces - 122 results found.
NameDescriptionTypePackageFramework
AsyncRecoveryAsynchronous message replay and sequence number recovery interface.Interfaceakka.persistence.journalAkka
AsyncRecoveryJava API: asynchronous message replay and sequence number recovery interface.Classakka.persistence.journal.japiAkka
AsyncReplayTimeoutExceptionThrown if replay inactivity exceeds a specified timeout.Classakka.persistence.journalAkka
AsyncWriteJournalAbstract journal, optimized for asynchronous, non-blocking writes.Interfaceakka.persistence.journalAkka
AsyncWriteJournalJava API: abstract journal, optimized for asynchronous, non-blocking writes.Classakka.persistence.journal.japiAkka
AsyncWriteJournal$Classakka.persistence.journalAkka
AsyncWriteJournal .DesequencedClassakka.persistence.journal.AsyncWriteJournalAkka
AsyncWriteJournal .Desequenced$Classakka.persistence.journal.AsyncWriteJournalAkka
AsyncWriteJournal .ResequencerClassakka.persistence.journal.AsyncWriteJournalAkka
AsyncWriteProxy A journal that delegates actual storage to a target actor.Interfaceakka.persistence.journalAkka
AsyncWriteProxy$Classakka.persistence.journalAkka
AsyncWriteProxy .InitTimeout$Classakka.persistence.journal.AsyncWriteProxyAkka
AsyncWriteProxy .SetStoreClassakka.persistence.journal.AsyncWriteProxyAkka
AsyncWriteProxy .SetStore$Classakka.persistence.journal.AsyncWriteProxyAkka
AsyncWriteTargetClassakka.persistence.journalAkka
AsyncWriteTarget$Classakka.persistence.journalAkka
AsyncWriteTarget .DeleteMessagesToClassakka.persistence.journal.AsyncWriteTargetAkka
AsyncWriteTarget .DeleteMessagesTo$Classakka.persistence.journal.AsyncWriteTargetAkka
AsyncWriteTarget .ReplayFailureClassakka.persistence.journal.AsyncWriteTargetAkka
AsyncWriteTarget .ReplayFailure$Classakka.persistence.journal.AsyncWriteTargetAkka
AsyncWriteTarget .ReplayMessagesClassakka.persistence.journal.AsyncWriteTargetAkka
AsyncWriteTarget .ReplayMessages$Classakka.persistence.journal.AsyncWriteTargetAkka
AsyncWriteTarget .ReplaySuccessClassakka.persistence.journal.AsyncWriteTargetAkka
AsyncWriteTarget .ReplaySuccess$Classakka.persistence.journal.AsyncWriteTargetAkka
AsyncWriteTarget .WriteMessagesClassakka.persistence.journal.AsyncWriteTargetAkka
AsyncWriteTarget .WriteMessages$Classakka.persistence.journal.AsyncWriteTargetAkka
EmptyEventSeq$Classakka.persistence.journalAkka
EventAdapterAn EventAdapter is both a WriteEventAdapter and a ReadEventAdapter.Interfaceakka.persistence.journalAkka
EventAdaptersEventAdapters serves as a per-journal collection of bound event adapters.Classakka.persistence.journalAkka
EventAdapters$Classakka.persistence.journalAkka
EventAdapters .CombinedReadEventAdapterClassakka.persistence.journal.EventAdaptersAkka
EventAdapters .CombinedReadEventAdapter$Classakka.persistence.journal.EventAdaptersAkka
EventSeqClassakka.persistence.journalAkka
EventSeq$Classakka.persistence.journalAkka
EventsSeqClassakka.persistence.journalAkka
EventsSeq$Classakka.persistence.journalAkka
IdentityEventAdapterNo-op model adapter which passes through the incoming events as-is.Classakka.persistence.journalAkka
IdentityEventAdapter$No-op model adapter which passes through the incoming events as-is.Classakka.persistence.journalAkka
IdentityEventAdaptersClassakka.persistence.journalAkka
IdentityEventAdapters$Classakka.persistence.journalAkka
InmemJournal In-memory journal for testing purposes only.Classakka.persistence.journal.inmemAkka
InmemMessagesInterfaceakka.persistence.journal.inmemAkka
InmemStoreClassakka.persistence.journal.inmemAkka
JournalCapabilityFlagsWhen true enables tests which check if the Journal properly rejects writes of objects which are not java.Interfaceakka.persistenceAkka
JournalPerfSpecThis spec measures execution times of the basic operations that an PersistentActor provides, using the provided Journal (plugin).Classakka.persistence.journalAkka
JournalPerfSpec$Classakka.persistence.journalAkka
JournalPerfSpec .BenchActorClassakka.persistence.journal.JournalPerfSpecAkka
JournalPerfSpec .CmdClassakka.persistence.journal.JournalPerfSpecAkka
JournalPerfSpec .Cmd$Classakka.persistence.journal.JournalPerfSpecAkka
JournalPerfSpec .ResetCounter$Classakka.persistence.journal.JournalPerfSpecAkka
JournalProtocol Messages exchanged between persistent actors, views and a journal.Classakka.persistenceAkka
JournalProtocol$ Messages exchanged between persistent actors, views and a journal.Classakka.persistenceAkka
JournalProtocol .DeleteMessagesToRequest to delete all persistent messages with sequence numbers up to toSequenceNrSee Also:Serialized FormClassakka.persistence.JournalProtocolAkka
JournalProtocol .DeleteMessagesTo$Classakka.persistence.JournalProtocolAkka
JournalProtocol .LoopMessageSuccessReply message to a JournalProtocol.Classakka.persistence.JournalProtocolAkka
JournalProtocol .LoopMessageSuccess$Classakka.persistence.JournalProtocolAkka
JournalProtocol .RecoverySuccessReply message to a successful JournalProtocol.Classakka.persistence.JournalProtocolAkka
JournalProtocol .RecoverySuccess$Classakka.persistence.JournalProtocolAkka
JournalProtocol .ReplayedMessageReply message to a JournalProtocol.Classakka.persistence.JournalProtocolAkka
JournalProtocol .ReplayedMessage$Classakka.persistence.JournalProtocolAkka
JournalProtocol .ReplayMessagesRequest to replay messages to persistentActor.Classakka.persistence.JournalProtocolAkka
JournalProtocol .ReplayMessages$Classakka.persistence.JournalProtocolAkka
JournalProtocol .ReplayMessagesFailureReply message to a failed JournalProtocol.Classakka.persistence.JournalProtocolAkka
JournalProtocol .ReplayMessagesFailure$Classakka.persistence.JournalProtocolAkka
JournalProtocol .WriteMessageFailureReply message to a failed JournalProtocol.Classakka.persistence.JournalProtocolAkka
JournalProtocol .WriteMessageFailure$Classakka.persistence.JournalProtocolAkka
JournalProtocol .WriteMessageRejectedReply message to a rejected JournalProtocol.Classakka.persistence.JournalProtocolAkka
JournalProtocol .WriteMessageRejected$Classakka.persistence.JournalProtocolAkka
JournalProtocol .WriteMessagesRequest to write messages.Classakka.persistence.JournalProtocolAkka
JournalProtocol .WriteMessages$Classakka.persistence.JournalProtocolAkka
JournalProtocol .WriteMessagesFailedReply message to a failed JournalProtocol.Classakka.persistence.JournalProtocolAkka
JournalProtocol .WriteMessagesFailed$Classakka.persistence.JournalProtocolAkka
JournalProtocol .WriteMessagesSuccessful$Reply message to a successful JournalProtocol.Classakka.persistence.JournalProtocolAkka
JournalProtocol .WriteMessageSuccessReply message to a successful JournalProtocol.Classakka.persistence.JournalProtocolAkka
JournalProtocol .WriteMessageSuccess$Classakka.persistence.JournalProtocolAkka
JournalSpecThis spec aims to verify custom akka-persistence Journal implementations.Classakka.persistence.journalAkka
JournalSpec$Classakka.persistence.journalAkka
KeyClassakka.persistence.journal.leveldbAkka
Key$Classakka.persistence.journal.leveldbAkka
LeveldbIdMapping LevelDB backed persistent mapping of String-based persistent actor ids to numeric ids.Interfaceakka.persistence.journal.leveldbAkka
LeveldbJournal Journal backed by a local LevelDB store.Classakka.persistence.journal.leveldbAkka
LeveldbJournal$Classakka.persistence.journal.leveldbAkka
LeveldbJournal .CurrentPersistenceIdsClassakka.persistence.journal.leveldb.LeveldbJournalAkka
LeveldbJournal .CurrentPersistenceIds$Classakka.persistence.journal.leveldb.LeveldbJournalAkka
LeveldbJournal .EventAppendedClassakka.persistence.journal.leveldb.LeveldbJournalAkka
LeveldbJournal .EventAppended$Classakka.persistence.journal.leveldb.LeveldbJournalAkka
LeveldbJournal .PersistenceIdAddedClassakka.persistence.journal.leveldb.LeveldbJournalAkka
LeveldbJournal .PersistenceIdAdded$Classakka.persistence.journal.leveldb.LeveldbJournalAkka
LeveldbJournal .ReplayedTaggedMessageClassakka.persistence.journal.leveldb.LeveldbJournalAkka
LeveldbJournal .ReplayedTaggedMessage$Classakka.persistence.journal.leveldb.LeveldbJournalAkka
LeveldbJournal .ReplayTaggedMessagesClassakka.persistence.journal.leveldb.LeveldbJournalAkka
LeveldbJournal .ReplayTaggedMessages$Classakka.persistence.journal.leveldb.LeveldbJournalAkka
LeveldbJournal .SubscribeAllPersistenceIds$Subscribe the sender to current and new persistenceIds.Classakka.persistence.journal.leveldb.LeveldbJournalAkka
LeveldbJournal .SubscribePersistenceIdSubscribe the sender to changes (appended events) for a specific persistenceId.Classakka.persistence.journal.leveldb.LeveldbJournalAkka
LeveldbJournal .SubscribePersistenceId$Classakka.persistence.journal.leveldb.LeveldbJournalAkka
LeveldbJournal .SubscribeTagSubscribe the sender to changes (appended events) for a specific tag.Classakka.persistence.journal.leveldb.LeveldbJournalAkka
LeveldbJournal .SubscribeTag$Classakka.persistence.journal.leveldb.LeveldbJournalAkka
LeveldbJournal .TaggedEventAppendedClassakka.persistence.journal.leveldb.LeveldbJournalAkka
LeveldbJournal .TaggedEventAppended$Classakka.persistence.journal.leveldb.LeveldbJournalAkka
LeveldbRecovery LevelDB backed message replay and sequence number recovery.Interfaceakka.persistence.journal.leveldbAkka
LeveldbStoreInterfaceakka.persistence.journal.leveldbAkka
NoopReadEventAdapterClassakka.persistence.journalAkka
NoopReadEventAdapter$Classakka.persistence.journalAkka
NoopWriteEventAdapterClassakka.persistence.journalAkka
NoopWriteEventAdapter$Classakka.persistence.journalAkka
ReadEventAdapterFacility to convert from and to specialised data models, as may be required by specialized persistence Journals.Interfaceakka.persistence.journalAkka
ReplayFilterClassakka.persistence.journalAkka
ReplayFilter$ Detect corrupt event stream during replay.Classakka.persistence.journalAkka
ReplayFilter .Disabled$Classakka.persistence.journal.ReplayFilterAkka
ReplayFilter .Fail$Classakka.persistence.journal.ReplayFilterAkka
ReplayFilter .RepairByDiscardOld$Classakka.persistence.journal.ReplayFilterAkka
ReplayFilter .Warn$Classakka.persistence.journal.ReplayFilterAkka
ReplayMediatorClassakka.persistence.journalAkka
SharedLeveldbJournal Journal backed by a SharedLeveldbStore.Classakka.persistence.journal.leveldbAkka
SharedLeveldbJournal$Classakka.persistence.journal.leveldbAkka
SharedLeveldbStoreA LevelDB store that can be shared by multiple actor systems.Classakka.persistence.journal.leveldbAkka
SingleEventSeqClassakka.persistence.journalAkka
SingleEventSeq$Classakka.persistence.journalAkka
TaggedThe journal may support tagging of events that are used by the EventsByTag query and it may support specifying the tags via anClassakka.persistence.journalAkka
Tagged$Classakka.persistence.journalAkka
WriteEventAdapterFacility to convert to specialised data models, as may be required by specialized persistence Journals.Interfaceakka.persistence.journalAkka
WriteJournalBaseInterfaceakka.persistence.journalAkka