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
Actor.emptyBehavior$, Actor.ignoringBehavior$
Constructor and Description |
---|
SharedLeveldbJournal() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
aroundPreStart, aroundReceive, asyncDeleteMessagesTo, asyncReadHighestSequenceNr, asyncReplayMessages, asyncWriteMessages
isReplayFilterEnabled, receive
adaptFromJournal, adaptToJournal, preparePersistentBatch
postStop, preRestart
aroundPostRestart, aroundPostStop, aroundPreRestart, postRestart, preStart, sender, supervisorStrategy, unhandled
actorCell, clearStash, enqueueFirst, prepend, stash, unstash, unstashAll, unstashAll
log
public static void setStore(ActorRef store, ActorSystem system)
store
for the given actor system
.
store
- (undocumented)system
- (undocumented)SharedLeveldbStore
public static final ActorRef sender()
protected static void aroundPostStop()
protected static void aroundPreRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message)
protected static void aroundPostRestart(java.lang.Throwable reason)
public static SupervisorStrategy supervisorStrategy()
public static void preStart() throws java.lang.Exception
java.lang.Exception
public static void postRestart(java.lang.Throwable reason) throws java.lang.Exception
java.lang.Exception
public static void unhandled(java.lang.Object message)
protected abstract static void akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
protected abstract static void akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
public static EventAdapters akka$persistence$journal$WriteJournalBase$$eventAdapters()
protected static scala.collection.immutable.Seq<AtomicWrite> preparePersistentBatch(scala.collection.immutable.Seq<PersistentEnvelope> rb)
public static final scala.collection.immutable.Seq<PersistentRepr> adaptFromJournal(PersistentRepr repr)
public static final PersistentRepr adaptToJournal(PersistentRepr repr)
protected abstract static void akka$persistence$journal$WriteJournalBase$_setter_$persistence_$eq(Persistence x$1)
protected abstract static void akka$persistence$journal$WriteJournalBase$_setter_$akka$persistence$journal$WriteJournalBase$$eventAdapters_$eq(EventAdapters x$1)
public static Persistence akka$persistence$journal$AsyncWriteJournal$$extension()
public static boolean akka$persistence$journal$AsyncWriteJournal$$publish()
public static com.typesafe.config.Config akka$persistence$journal$AsyncWriteJournal$$config()
public static CircuitBreaker akka$persistence$journal$AsyncWriteJournal$$breaker()
public static ReplayFilter.Mode akka$persistence$journal$AsyncWriteJournal$$replayFilterMode()
public static int akka$persistence$journal$AsyncWriteJournal$$replayFilterWindowSize()
public static int akka$persistence$journal$AsyncWriteJournal$$replayFilterMaxOldWriters()
public static ActorRef akka$persistence$journal$AsyncWriteJournal$$resequencer()
public static long akka$persistence$journal$AsyncWriteJournal$$resequencerCounter()
public static void akka$persistence$journal$AsyncWriteJournal$$resequencerCounter_$eq(long x$1)
public static final scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
protected abstract static void akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$extension_$eq(Persistence x$1)
protected abstract static void akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$publish_$eq(boolean x$1)
protected abstract static void akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$config_$eq(com.typesafe.config.Config x$1)
protected abstract static void akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$breaker_$eq(CircuitBreaker x$1)
protected abstract static void akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$replayFilterMode_$eq(ReplayFilter.Mode x$1)
protected abstract static void akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$replayFilterWindowSize_$eq(int x$1)
protected abstract static void akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$replayFilterMaxOldWriters_$eq(int x$1)
protected abstract static void akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$resequencer_$eq(ActorRef x$1)
protected abstract static void akka$persistence$journal$AsyncWriteJournal$_setter_$receiveWriteJournal_$eq(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> x$1)
public static scala.collection.immutable.Vector<Envelope> akka$actor$StashSupport$$theStash()
public static void akka$actor$StashSupport$$theStash_$eq(scala.collection.immutable.Vector<Envelope> x$1)
public static int akka$actor$StashSupport$$capacity()
public static void stash()
public static void prepend(scala.collection.immutable.Seq<Envelope> others)
public static void unstash()
public static void unstashAll()
public static void unstashAll(scala.Function1<java.lang.Object,java.lang.Object> filterPredicate)
public static scala.collection.immutable.Vector<Envelope> clearStash()
protected abstract static void akka$actor$StashSupport$_setter_$akka$actor$StashSupport$$capacity_$eq(int x$1)
protected abstract static void akka$actor$StashSupport$_setter_$mailbox_$eq(DequeBasedMessageQueueSemantics x$1)
public static void preRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message)
public static void postStop()
public static LoggingAdapter akka$actor$ActorLogging$$_log()
public static void akka$actor$ActorLogging$$_log_$eq(LoggingAdapter x$1)
public static LoggingAdapter log()
public static boolean akka$persistence$journal$AsyncWriteProxy$$isInitialized()
public static void akka$persistence$journal$AsyncWriteProxy$$isInitialized_$eq(boolean x$1)
public static boolean akka$persistence$journal$AsyncWriteProxy$$isInitTimedOut()
public static void akka$persistence$journal$AsyncWriteProxy$$isInitTimedOut_$eq(boolean x$1)
protected static void store_$eq(scala.Option<ActorRef> x$1)
public static scala.concurrent.Future<scala.runtime.Nothing$> akka$persistence$journal$AsyncWriteProxy$$storeNotInitialized()
protected static void aroundPreStart()
protected static void aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive, java.lang.Object msg)
public static scala.concurrent.Future<scala.collection.immutable.Seq<scala.util.Try<scala.runtime.BoxedUnit>>> asyncWriteMessages(scala.collection.immutable.Seq<AtomicWrite> messages)
public static scala.concurrent.Future<scala.runtime.BoxedUnit> asyncDeleteMessagesTo(java.lang.String persistenceId, long toSequenceNr)
public static scala.concurrent.Future<scala.runtime.BoxedUnit> asyncReplayMessages(java.lang.String persistenceId, long fromSequenceNr, long toSequenceNr, long max, scala.Function1<PersistentRepr,scala.runtime.BoxedUnit> replayCallback)
public static scala.concurrent.Future<java.lang.Object> asyncReadHighestSequenceNr(java.lang.String persistenceId, long fromSequenceNr)
protected abstract static void akka$persistence$journal$AsyncWriteProxy$_setter_$akka$persistence$journal$AsyncWriteProxy$$storeNotInitialized_$eq(scala.concurrent.Future<scala.runtime.Nothing$> x$1)
protected scala.Option<ActorRef> store()
store
in interface AsyncWriteProxy
public DequeBasedMessageQueueSemantics mailbox()
mailbox
in interface StashSupport
public final scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receiveWriteJournal()
receiveWriteJournal
in interface AsyncWriteJournal
public Persistence persistence()
persistence
in interface WriteJournalBase
public ActorContext context()
Actor
forward
.
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 a
UntypedActorContext
, which is the Java API of the actor
context.
context
in interface Actor
context
in interface StashSupport
public final ActorRef self()
Actor
self ! message
self
in interface Actor
self
in interface StashSupport
public 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