akka.persistence.journal.inmem

Class InmemJournal

java.lang.Object

akka.persistence.journal.inmem.InmemJournal

All Implemented Interfaces:

Actor, Stash, StashSupport, UnrestrictedStash, RequiresMessageQueue<DequeBasedMessageQueueSemantics>, AsyncRecovery, AsyncWriteJournal, AsyncWriteProxy, WriteJournalBase

public class InmemJournal
extends java.lang.Object
implements AsyncWriteProxy

INTERNAL API.

In-memory journal for testing purposes only.

Nested Class Summary

Nested classes/interfaces inherited from interface akka.persistence.journal.AsyncWriteProxy

AsyncWriteProxy.SetStore, AsyncWriteProxy.SetStore$

Nested classes/interfaces inherited from interface akka.persistence.journal.AsyncWriteJournal

AsyncWriteJournal.Desequenced, AsyncWriteJournal.Desequenced$, AsyncWriteJournal.Resequencer

Nested classes/interfaces inherited from interface akka.actor.Actor

Actor.emptyBehavior$, Actor.ignoringBehavior$

Constructor Summary

Constructors

Constructor and Description
InmemJournal()

Method Summary

Modifier and Type	Method and Description
void	preStart() User overridable callback.
Timeout	timeout()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface akka.persistence.journal.AsyncWriteProxy

asyncDeleteMessagesTo, asyncReadHighestSequenceNr, asyncReplayMessages, asyncWriteMessages, initialized, receive, store

Methods inherited from interface akka.persistence.journal.AsyncWriteJournal

extension, publish, resequencer, resequencerCounter

Methods inherited from interface akka.persistence.journal.WriteJournalBase

persistentPrepareWrite, preparePersistentBatch

Methods inherited from interface akka.actor.UnrestrictedStash

postStop, preRestart

Methods inherited from interface akka.actor.Actor

aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, self, sender, supervisorStrategy, unhandled

Methods inherited from interface akka.actor.StashSupport

actorCell, capacity, clearStash, context, enqueueFirst, mailbox, prepend, self, stash, theStash, unstash, unstashAll, unstashAll

Constructor Detail

InmemJournal

public InmemJournal()

Method Detail

timeout

public Timeout timeout()

Specified by:

timeout in interface AsyncWriteProxy

preStart

public void preStart()

Description copied from interface: Actor

User overridable callback.

Is called when an Actor is started. Actors are automatically started asynchronously when created. Empty default implementation.

Specified by:

preStart in interface Actor