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

        public static com.typesafe.config.Config configToEnableJavaSerializationForTest()
        Configuration to enable TestJavaSerializer in akka-testkit for for the messages used by SharedLeveldbJournal.

        For testing only.

        Returns:
        (undocumented)
      • 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)