Package org.apache.pekko.persistence.journal

Class JournalPerfSpec.BenchActor

    • Constructor Detail

      • BenchActor

        public BenchActor​(java.lang.String persistenceId,
                  ActorRef replyTo,
                  int replyAfter)

    • Method Detail

      • 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

      • counter

        public int counter()

      • counter_$eq

        public void counter_$eq​(int x$1)

      • 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

      • receiveCommand

        public scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receiveCommand()
        Description copied from interface: Eventsourced
        Command handler. Typically validates commands against current state (and/or by communication with other actors). On successful validation, one or more events are derived from a command and these events are then persisted by calling persist.
        Specified by:
        receiveCommand in interface Eventsourced

      • receiveRecover

        public scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receiveRecover()
        Description copied from interface: Eventsourced
        Recovery handler that receives persisted events during recovery. If a state snapshot has been captured and saved, this handler will receive a pekko.persistence.SnapshotOffer message followed by events that are younger than the offered snapshot.

        This handler must not have side-effects other than changing persistent actor state i.e. it should not perform actions that may fail, such as interacting with external services, for example.

        If there is a problem with recovering the state of the actor from the journal, the error will be logged and the actor will be stopped.

        Specified by:
        receiveRecover in interface Eventsourced
        See Also:
        pekko.persistence.Recovery

      • 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