public class SharedLeveldbJournal extends java.lang.Object implements AsyncWriteProxy
Journal backed by a SharedLeveldbStore
. For testing only.
AsyncWriteProxy.InitTimeout$, AsyncWriteProxy.SetStore, AsyncWriteProxy.SetStore$
AsyncWriteJournal.Desequenced, AsyncWriteJournal.Desequenced$, AsyncWriteJournal.Resequencer
Constructor and Description |
---|
SharedLeveldbJournal() |
Modifier and Type | Method and Description |
---|---|
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receivePluginInternal()
Plugin API
|
static void |
setStore(akka.actor.ActorRef store,
akka.actor.ActorSystem system)
Sets the shared LevelDB
store for the given actor system . |
akka.util.Timeout |
timeout() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
aroundPreStart, aroundReceive, asyncDeleteMessagesTo, asyncReadHighestSequenceNr, asyncReplayMessages, asyncWriteMessages, isInitialized, isInitTimedOut, store, storeNotInitialized
breaker, config, extension, isReplayFilterEnabled, publish, receive, receiveWriteJournal, replayFilterMaxOldWriters, replayFilterMode, replayFilterWindowSize, resequencer, resequencerCounter
adaptFromJournal, adaptToJournal, eventAdapters, persistence, preparePersistentBatch
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, context, postRestart, preStart, self, sender, supervisorStrategy, unhandled
akka$actor$StashSupport$_setter_$akka$actor$StashSupport$$capacity_$eq, akka$actor$StashSupport$_setter_$mailbox_$eq, akka$actor$StashSupport$$capacity, akka$actor$StashSupport$$theStash_$eq, akka$actor$StashSupport$$theStash, clearStash, context, mailbox, prepend, self, stash, unstash, unstashAll, unstashAll
public static void setStore(akka.actor.ActorRef store, akka.actor.ActorSystem system)
store
for the given actor system
.
store
- (undocumented)system
- (undocumented)SharedLeveldbStore
public akka.util.Timeout timeout()
timeout
in interface AsyncWriteProxy
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