Class SharedLeveldbJournal

    • 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
      • sender

        public static final ActorRef sender()
      • aroundPostStop

        protected static void aroundPostStop()
      • aroundPreRestart

        protected static void aroundPreRestart​(java.lang.Throwable reason,
                                               scala.Option<java.lang.Object> message)
      • aroundPostRestart

        protected static void aroundPostRestart​(java.lang.Throwable reason)
      • preStart

        public static void preStart()
                             throws java.lang.Exception
        Throws:
        java.lang.Exception
      • postRestart

        public static void postRestart​(java.lang.Throwable reason)
                                throws java.lang.Exception
        Throws:
        java.lang.Exception
      • unhandled

        public static void unhandled​(java.lang.Object message)
      • akka$persistence$journal$WriteJournalBase$$eventAdapters

        public static EventAdapters akka$persistence$journal$WriteJournalBase$$eventAdapters()
      • preparePersistentBatch

        protected static scala.collection.immutable.Seq<AtomicWrite> preparePersistentBatch​(scala.collection.immutable.Seq<PersistentEnvelope> rb)
      • akka$persistence$journal$WriteJournalBase$_setter_$akka$persistence$journal$WriteJournalBase$$eventAdapters_$eq

        protected abstract static void akka$persistence$journal$WriteJournalBase$_setter_$akka$persistence$journal$WriteJournalBase$$eventAdapters_$eq​(EventAdapters x$1)
      • akka$persistence$journal$AsyncWriteJournal$$extension

        public static Persistence akka$persistence$journal$AsyncWriteJournal$$extension()
      • akka$persistence$journal$AsyncWriteJournal$$publish

        public static boolean akka$persistence$journal$AsyncWriteJournal$$publish()
      • akka$persistence$journal$AsyncWriteJournal$$config

        public static com.typesafe.config.Config akka$persistence$journal$AsyncWriteJournal$$config()
      • akka$persistence$journal$AsyncWriteJournal$$breaker

        public static CircuitBreaker akka$persistence$journal$AsyncWriteJournal$$breaker()
      • akka$persistence$journal$AsyncWriteJournal$$replayFilterMode

        public static ReplayFilter.Mode akka$persistence$journal$AsyncWriteJournal$$replayFilterMode()
      • akka$persistence$journal$AsyncWriteJournal$$replayFilterWindowSize

        public static int akka$persistence$journal$AsyncWriteJournal$$replayFilterWindowSize()
      • akka$persistence$journal$AsyncWriteJournal$$replayFilterMaxOldWriters

        public static int akka$persistence$journal$AsyncWriteJournal$$replayFilterMaxOldWriters()
      • akka$persistence$journal$AsyncWriteJournal$$resequencer

        public static ActorRef akka$persistence$journal$AsyncWriteJournal$$resequencer()
      • akka$persistence$journal$AsyncWriteJournal$$resequencerCounter

        public static long akka$persistence$journal$AsyncWriteJournal$$resequencerCounter()
      • akka$persistence$journal$AsyncWriteJournal$$resequencerCounter_$eq

        public static void akka$persistence$journal$AsyncWriteJournal$$resequencerCounter_$eq​(long x$1)
      • receive

        public static final scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receive()
      • akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$extension_$eq

        protected abstract static void akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$extension_$eq​(Persistence x$1)
      • akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$publish_$eq

        protected abstract static void akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$publish_$eq​(boolean x$1)
      • akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$config_$eq

        protected abstract static void akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$config_$eq​(com.typesafe.config.Config x$1)
      • akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$breaker_$eq

        protected abstract static void akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$breaker_$eq​(CircuitBreaker x$1)
      • akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$replayFilterMode_$eq

        protected abstract static void akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$replayFilterMode_$eq​(ReplayFilter.Mode x$1)
      • akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$replayFilterWindowSize_$eq

        protected abstract static void akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$replayFilterWindowSize_$eq​(int x$1)
      • akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$replayFilterMaxOldWriters_$eq

        protected abstract static void akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$replayFilterMaxOldWriters_$eq​(int x$1)
      • akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$resequencer_$eq

        protected abstract static void akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$resequencer_$eq​(ActorRef x$1)
      • akka$actor$StashSupport$$theStash

        public static scala.collection.immutable.Vector<Envelope> akka$actor$StashSupport$$theStash()
      • akka$actor$StashSupport$$theStash_$eq

        public static void akka$actor$StashSupport$$theStash_$eq​(scala.collection.immutable.Vector<Envelope> x$1)
      • akka$actor$StashSupport$$capacity

        public static int akka$actor$StashSupport$$capacity()
      • stash

        public static void stash()
      • prepend

        public static void prepend​(scala.collection.immutable.Seq<Envelope> others)
      • unstash

        public static void unstash()
      • unstashAll

        public static void unstashAll()
      • unstashAll

        public static void unstashAll​(scala.Function1<java.lang.Object,​java.lang.Object> filterPredicate)
      • clearStash

        public static scala.collection.immutable.Vector<Envelope> clearStash()
      • akka$actor$StashSupport$_setter_$akka$actor$StashSupport$$capacity_$eq

        protected abstract static void akka$actor$StashSupport$_setter_$akka$actor$StashSupport$$capacity_$eq​(int x$1)
      • preRestart

        public static void preRestart​(java.lang.Throwable reason,
                                      scala.Option<java.lang.Object> message)
      • postStop

        public static void postStop()
      • akka$actor$ActorLogging$$_log

        public static LoggingAdapter akka$actor$ActorLogging$$_log()
      • akka$actor$ActorLogging$$_log_$eq

        public static void akka$actor$ActorLogging$$_log_$eq​(LoggingAdapter x$1)
      • akka$persistence$journal$AsyncWriteProxy$$isInitialized

        public static boolean akka$persistence$journal$AsyncWriteProxy$$isInitialized()
      • akka$persistence$journal$AsyncWriteProxy$$isInitialized_$eq

        public static void akka$persistence$journal$AsyncWriteProxy$$isInitialized_$eq​(boolean x$1)
      • akka$persistence$journal$AsyncWriteProxy$$isInitTimedOut

        public static boolean akka$persistence$journal$AsyncWriteProxy$$isInitTimedOut()
      • akka$persistence$journal$AsyncWriteProxy$$isInitTimedOut_$eq

        public static void akka$persistence$journal$AsyncWriteProxy$$isInitTimedOut_$eq​(boolean x$1)
      • akka$persistence$journal$AsyncWriteProxy$$storeNotInitialized

        public static scala.concurrent.Future<scala.runtime.Nothing$> akka$persistence$journal$AsyncWriteProxy$$storeNotInitialized()
      • aroundPreStart

        protected static void aroundPreStart()
      • aroundReceive

        protected static void aroundReceive​(scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receive,
                                            java.lang.Object msg)
      • asyncWriteMessages

        public static scala.concurrent.Future<scala.collection.immutable.Seq<scala.util.Try<scala.runtime.BoxedUnit>>> asyncWriteMessages​(scala.collection.immutable.Seq<AtomicWrite> messages)
      • asyncDeleteMessagesTo

        public static scala.concurrent.Future<scala.runtime.BoxedUnit> asyncDeleteMessagesTo​(java.lang.String persistenceId,
                                                                                             long toSequenceNr)
      • asyncReplayMessages

        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)
      • asyncReadHighestSequenceNr

        public static scala.concurrent.Future<java.lang.Object> asyncReadHighestSequenceNr​(java.lang.String persistenceId,
                                                                                           long fromSequenceNr)
      • akka$persistence$journal$AsyncWriteProxy$_setter_$akka$persistence$journal$AsyncWriteProxy$$storeNotInitialized_$eq

        protected abstract static void akka$persistence$journal$AsyncWriteProxy$_setter_$akka$persistence$journal$AsyncWriteProxy$$storeNotInitialized_$eq​(scala.concurrent.Future<scala.runtime.Nothing$> x$1)
      • receiveWriteJournal

        public final scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receiveWriteJournal()
        Specified by:
        receiveWriteJournal in interface AsyncWriteJournal
      • 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 as 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 AbstractActor.ActorContext, which is the Java API of the actor context.

        Specified by:
        context in interface Actor
        Specified by:
        context in interface StashSupport
        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 interface Actor
        Specified by:
        self in interface StashSupport
        Returns:
        (undocumented)
      • akka$actor$Actor$_setter_$context_$eq

        protected void akka$actor$Actor$_setter_$context_$eq​(ActorContext x$1)
        Description copied from interface: Actor
        Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such as 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 AbstractActor.ActorContext, which is the Java API of the actor context.

        Specified by:
        akka$actor$Actor$_setter_$context_$eq in interface Actor
        Parameters:
        x$1 - (undocumented)
      • 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 interface Actor
        Parameters:
        x$1 - (undocumented)
      • receivePluginInternal

        public scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receivePluginInternal()
        Description copied from interface: AsyncWriteJournal
        Plugin API

        Allows plugin implementers to use f pipeTo self and handle additional messages for implementing advanced features

        Specified by:
        receivePluginInternal in interface AsyncWriteJournal
        Returns:
        (undocumented)