Package org.apache.pekko.persistence.journal

Class PersistencePluginProxy

java.lang.Object
org.apache.pekko.persistence.journal.PersistencePluginProxy
All Implemented Interfaces:
Actor, ActorLogging, Stash, StashSupport, UnrestrictedStash, RequiresMessageQueue<DequeBasedMessageQueueSemantics>
public final class PersistencePluginProxy extends Object implements Actor, Stash, ActorLogging

  • Constructor Details

    • PersistencePluginProxy

      public PersistencePluginProxy(com.typesafe.config.Config config)

  • Method Details

    • setTargetLocation

      public static void setTargetLocation(ActorSystem system, Address address)

    • start

      public static void start(ActorSystem system)

    • org$apache$pekko$actor$StashSupport$_setter_$mailbox_$eq

      protected void org$apache$pekko$actor$StashSupport$_setter_$mailbox_$eq(DequeBasedMessageQueueSemantics x$1)
      Specified by:
      org$apache$pekko$actor$StashSupport$_setter_$mailbox_$eq in interface StashSupport

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

      pekko.actor.ActorContext is the Scala API. getContext returns a pekko.actor.AbstractActor.ActorContext, which is the Java API of the actor context.

      Specified by:
      context in interface Actor
      Specified by:
      context in interface StashSupport

    • 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

    • org$apache$pekko$actor$Actor$_setter_$context_$eq

      protected void org$apache$pekko$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!

      pekko.actor.ActorContext is the Scala API. getContext returns a pekko.actor.AbstractActor.ActorContext, which is the Java API of the actor context.

      Specified by:
      org$apache$pekko$actor$Actor$_setter_$context_$eq in interface Actor

    • org$apache$pekko$actor$Actor$_setter_$self_$eq

      protected final void org$apache$pekko$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:
      org$apache$pekko$actor$Actor$_setter_$self_$eq in interface Actor

    • preStart

      public void preStart()
      Description copied from interface: Actor
      User overridable callback.

      Is called when an Actor is started. Actors are automatically started asynchronously when created. Empty default implementation.
      Specified by:
      preStart in interface Actor

    • receive

      public scala.PartialFunction<Object,scala.runtime.BoxedUnit> receive()
      Description copied from interface: Actor
      Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.
      Specified by:
      receive in interface Actor

    • init

      public scala.PartialFunction<Object,scala.runtime.BoxedUnit> init()

    • becomeIdentifying

      public void becomeIdentifying(Address address)

    • sendIdentify

      public void sendIdentify(Address address)

    • identifying

      public scala.PartialFunction<Object,scala.runtime.BoxedUnit> identifying(Address address)

    • active

      public scala.PartialFunction<Object,scala.runtime.BoxedUnit> active(ActorRef targetJournal, boolean targetAtThisNode)

    • initTimedOut

      public scala.PartialFunction<Object,scala.runtime.BoxedUnit> initTimedOut()