Package akka.persistence.journal.leveldb
Class SharedLeveldbJournal
- java.lang.Object
-
- akka.persistence.journal.leveldb.SharedLeveldbJournal
-
- All Implemented Interfaces:
Actor
,ActorLogging
,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.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
-
Nested classes/interfaces inherited from interface akka.persistence.journal.AsyncWriteJournal
AsyncWriteJournal.Desequenced, AsyncWriteJournal.Desequenced$, AsyncWriteJournal.Resequencer
-
Nested classes/interfaces inherited from interface akka.persistence.journal.AsyncWriteProxy
AsyncWriteProxy.InitTimeout$, AsyncWriteProxy.SetStore, AsyncWriteProxy.SetStore$
-
-
Constructor Summary
Constructors Constructor Description SharedLeveldbJournal()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
protected void
akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
The 'self' field holds the ActorRef for this actor.protected void
akka$actor$StashSupport$_setter_$mailbox_$eq(DequeBasedMessageQueueSemantics x$1)
protected void
akka$persistence$journal$AsyncWriteJournal$_setter_$receiveWriteJournal_$eq(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> x$1)
protected void
akka$persistence$journal$WriteJournalBase$_setter_$persistence_$eq(Persistence x$1)
ActorContext
context()
Scala API: Stores the context for this actor, including self, and sender.DequeBasedMessageQueueSemantics
mailbox()
Persistence
persistence()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
receivePluginInternal()
Plugin APIscala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
receiveWriteJournal()
ActorRef
self()
The 'self' field holds the ActorRef for this actor.static void
setStore(ActorRef store, ActorSystem system)
protected scala.Option<ActorRef>
store()
protected void
store_$eq(scala.Option<ActorRef> x$1)
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.actor.Actor
aroundPostRestart, aroundPostStop, aroundPreRestart, postRestart, preStart, sender, supervisorStrategy, unhandled
-
Methods inherited from interface akka.actor.ActorLogging
_log_$eq, log
-
Methods inherited from interface akka.persistence.journal.AsyncWriteJournal
isReplayFilterEnabled, receive, resequencerCounter_$eq
-
Methods inherited from interface akka.persistence.journal.AsyncWriteProxy
aroundPreStart, aroundReceive, asyncDeleteMessagesTo, asyncReadHighestSequenceNr, asyncReplayMessages, asyncWriteMessages, isInitialized_$eq, isInitTimedOut_$eq, super$aroundPreStart, super$aroundReceive
-
Methods inherited from interface akka.actor.StashSupport
actorCell, clearStash, enqueueFirst, prepend, stash, theStash_$eq, unstash, unstashAll, unstashAll
-
Methods inherited from interface akka.actor.UnrestrictedStash
postStop, preRestart, super$postStop, super$preRestart
-
Methods inherited from interface akka.persistence.journal.WriteJournalBase
adaptFromJournal, adaptToJournal, preparePersistentBatch
-
-
-
-
Method Detail
-
setStore
public static void setStore(ActorRef store, ActorSystem system)
-
store
protected scala.Option<ActorRef> store()
- Specified by:
store
in interfaceAsyncWriteProxy
-
store_$eq
protected void store_$eq(scala.Option<ActorRef> x$1)
- Specified by:
store_$eq
in interfaceAsyncWriteProxy
-
mailbox
public DequeBasedMessageQueueSemantics mailbox()
- Specified by:
mailbox
in interfaceStashSupport
-
akka$actor$StashSupport$_setter_$mailbox_$eq
protected void akka$actor$StashSupport$_setter_$mailbox_$eq(DequeBasedMessageQueueSemantics x$1)
- Specified by:
akka$actor$StashSupport$_setter_$mailbox_$eq
in interfaceStashSupport
-
receiveWriteJournal
public final scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receiveWriteJournal()
- Specified by:
receiveWriteJournal
in interfaceAsyncWriteJournal
-
akka$persistence$journal$AsyncWriteJournal$_setter_$receiveWriteJournal_$eq
protected final void akka$persistence$journal$AsyncWriteJournal$_setter_$receiveWriteJournal_$eq(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> x$1)
- Specified by:
akka$persistence$journal$AsyncWriteJournal$_setter_$receiveWriteJournal_$eq
in interfaceAsyncWriteJournal
-
persistence
public Persistence persistence()
- Specified by:
persistence
in interfaceWriteJournalBase
-
akka$persistence$journal$WriteJournalBase$_setter_$persistence_$eq
protected void akka$persistence$journal$WriteJournalBase$_setter_$persistence_$eq(Persistence x$1)
- Specified by:
akka$persistence$journal$WriteJournalBase$_setter_$persistence_$eq
in interfaceWriteJournalBase
-
context
public ActorContext context()
Description copied from interface:Actor
Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such asforward
.WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!
ActorContext
is the Scala API.getContext
returns aAbstractActor.ActorContext
, which is the Java API of the actor context.- Specified by:
context
in interfaceActor
- Specified by:
context
in interfaceStashSupport
- Returns:
- (undocumented)
-
self
public final ActorRef self()
Description copied from interface:Actor
The 'self' field holds the ActorRef for this actor. Can be used to send messages to itself:self ! message
- Specified by:
self
in interfaceActor
- Specified by:
self
in interfaceStashSupport
- Returns:
- (undocumented)
-
akka$actor$Actor$_setter_$context_$eq
protected void akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
- Specified by:
akka$actor$Actor$_setter_$context_$eq
in interfaceActor
-
akka$actor$Actor$_setter_$self_$eq
protected final void akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
Description copied from interface:Actor
The 'self' field holds the ActorRef for this actor. Can be used to send messages to itself:self ! message
- Specified by:
akka$actor$Actor$_setter_$self_$eq
in interfaceActor
- Parameters:
x$1
- (undocumented)
-
timeout
public Timeout timeout()
- Specified by:
timeout
in interfaceAsyncWriteProxy
-
receivePluginInternal
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receivePluginInternal()
Description copied from interface:AsyncWriteJournal
Plugin APIAllows plugin implementers to use
f pipeTo self
and handle additional messages for implementing advanced features- Specified by:
receivePluginInternal
in interfaceAsyncWriteJournal
- Returns:
- (undocumented)
-
-