akka.persistence.journal.leveldb
Class SharedLeveldbJournal

java.lang.Object
  akka.persistence.journal.leveldb.SharedLeveldbJournal

All Implemented Interfaces:

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

public class SharedLeveldbJournal
extends java.lang.Object
implements AsyncWriteProxy

INTERNAL API.

Journal backed by a SharedLeveldbStore. For testing 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$

Constructor Summary

SharedLeveldbJournal()

Method Summary

static void	setStore(ActorRef store, ActorSystem system) Sets the shared LevelDB store for the given actor system.
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

asyncDeleteMessages, asyncDeleteMessagesTo, asyncReadHighestSequenceNr, asyncReplayMessages, asyncWriteConfirmations, 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, preStart, 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

SharedLeveldbJournal

public SharedLeveldbJournal()

Method Detail

setStore

public static void setStore(ActorRef store,
                            ActorSystem system)

Sets the shared LevelDB store for the given actor system.

Parameters:

store - (undocumented)

system - (undocumented)

See Also:

SharedLeveldbStore

timeout

public Timeout timeout()

Specified by:

timeout in interface AsyncWriteProxy