public class LeveldbJournal extends java.lang.Object implements AsyncWriteJournal, LeveldbStore
Journal backed by a local LevelDB store. For production use.
AsyncWriteJournal.Desequenced, AsyncWriteJournal.Desequenced$, AsyncWriteJournal.Resequencer
Constructor and Description |
---|
LeveldbJournal() |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
configPath() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receivePluginInternal()
Plugin API
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
asyncDeleteMessagesTo, asyncWriteMessages, breaker, config, extension, isReplayFilterEnabled, publish, receive, receiveWriteJournal, replayFilterMaxOldWriters, replayFilterMode, replayFilterWindowSize, resequencer, resequencerCounter
addAllPersistenceIdsSubscriber, addPersistenceIdSubscriber, addTagSubscriber, addToMessageBatch, allPersistenceIdsSubscribers, asyncDeleteMessagesTo, asyncWriteMessages, config, hasAllPersistenceIdsSubscribers, hasPersistenceIdSubscribers, hasTagSubscribers, leveldb, leveldbDir, leveldbFactory, leveldbOptions, leveldbReadOptions, leveldbSnapshot, leveldbWriteOptions, nativeLeveldb, newPersistenceIdAdded, nextTagSequenceNr, notifyPersistenceIdChange, notifyTagChange, persistenceIdSubscribers, persistentFromBytes, persistentToBytes, postStop, preStart, removeSubscriber, serialization, tagAsPersistenceId, tagNumericId, tagPersistenceIdPrefix, tagSequenceNr, tagSubscribers, withBatch, withIterator
adaptFromJournal, adaptToJournal, eventAdapters, persistence, preparePersistentBatch
allPersistenceIds, idMap, idMapLock, idOffset, isNewPersistenceId, numericId, readIdMap, readIdMap, writeIdMapping
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, preRestart, self, sender, supervisorStrategy, unhandled
asyncReadHighestSequenceNr, asyncReplayMessages, asyncReplayTaggedMessages, readHighestSequenceNr, replayDispatcher, replayDispatcherId, replayMessages, replayTaggedMessages
public java.lang.String configPath()
configPath
in interface LeveldbStore
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receivePluginInternal()
AsyncWriteJournal
Allows plugin implementers to use f pipeTo self
and
handle additional messages for implementing advanced features
receivePluginInternal
in interface AsyncWriteJournal