public class InmemJournal extends java.lang.Object implements AsyncWriteProxy
In-memory journal for testing purposes only.
AsyncWriteProxy.InitTimeout$, AsyncWriteProxy.SetStore, AsyncWriteProxy.SetStore$
AsyncWriteJournal.Desequenced, AsyncWriteJournal.Desequenced$, AsyncWriteJournal.Resequencer
Constructor and Description |
---|
InmemJournal() |
Modifier and Type | Method and Description |
---|---|
void |
preStart() |
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, receivePluginInternal, 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, 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 akka.util.Timeout timeout()
timeout
in interface AsyncWriteProxy
public void preStart()
preStart
in interface akka.actor.Actor