Package org.apache.pekko.persistence

Class AbstractPersistentActorWithTimers

java.lang.Object

org.apache.pekko.actor.AbstractActor

org.apache.pekko.persistence.AbstractPersistentActorWithTimers

All Implemented Interfaces:

Actor, StashFactory, StashSupport, Timers, RequiresMessageQueue<DequeBasedMessageQueueSemantics>, AbstractPersistentActorLike, Eventsourced, PersistenceIdentity, PersistenceRecovery, PersistenceStash, Snapshotter

public abstract class AbstractPersistentActorWithTimers
extends AbstractActor
implements Timers, AbstractPersistentActorLike

Java API: Combination of AbstractPersistentActor and pekko.actor.AbstractActorWithTimers.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.pekko.actor.AbstractActor

AbstractActor.ActorContext, AbstractActor.Receive

Nested classes/interfaces inherited from interface org.apache.pekko.actor.Actor

Actor.emptyBehavior$, Actor.ignoringBehavior$

Nested classes/interfaces inherited from interface org.apache.pekko.persistence.Eventsourced

Eventsourced.AsyncHandlerInvocation, Eventsourced.AsyncHandlerInvocation$, Eventsourced.PendingHandlerInvocation, Eventsourced.RecoveryTick, Eventsourced.RecoveryTick$, Eventsourced.StashingHandlerInvocation, Eventsourced.StashingHandlerInvocation$, Eventsourced.State

Constructor Summary

Constructors

Constructor	Description
AbstractPersistentActorWithTimers()

Method Summary

Modifier and Type	Method	Description
protected void	aroundPostStop()	INTERNAL API.
protected void	aroundPreRestart(Throwable reason, scala.Option<Object> message)	INTERNAL API.
protected void	aroundReceive(scala.PartialFunction<Object,scala.runtime.BoxedUnit> receive, Object msg)	INTERNAL API.
protected ActorRef	journal()
protected void	org$apache$pekko$actor$StashSupport$_setter_$mailbox_$eq(DequeBasedMessageQueueSemantics x$1)
protected ActorRef	snapshotStore()	Snapshot store plugin actor.

Methods inherited from class org.apache.pekko.actor.AbstractActor

context, createReceive, emptyBehavior, getContext, getSelf, getSender, org$apache$pekko$actor$Actor$_setter_$context_$eq, org$apache$pekko$actor$Actor$_setter_$self_$eq, postRestart, postStop, preRestart, preRestart, preStart, receive, receiveBuilder, self, supervisorStrategy

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.pekko.persistence.AbstractPersistentActorLike

createReceive, createReceiveRecover, defer, deferAsync, persist, persistAll, persistAllAsync, persistAsync, receiveCommand, receiveRecover

Methods inherited from interface org.apache.pekko.actor.Actor

context, org$apache$pekko$actor$Actor$_setter_$context_$eq, org$apache$pekko$actor$Actor$_setter_$self_$eq, postRestart, postStop, preRestart, preStart, receive, self, sender, supervisorStrategy

Methods inherited from interface org.apache.pekko.persistence.Eventsourced

_lastSequenceNr_$eq, aroundPostRestart, aroundPreStart, batchAtomicWrite, changeState, currentState_$eq, deleteMessages, eventBatch_$eq, flushBatch, flushJournalBatch, internalDefer, internalDeferAsync, internalDeleteMessagesBeforeSnapshot, internalPersist, internalPersistAll, internalPersistAllAsync, internalPersistAsync, journalBatch_$eq, lastSequenceNr, log, nextSequenceNr, onPersistFailure, onPersistRejected, onRecoveryFailure, onReplaySuccess, peekApplyHandler, pendingStashingPersistInvocations_$eq, recovering, recoveryFinished, recoveryRunning, recoveryStarted, requestRecoveryPermit, sendBatchedEventsToJournal, sequenceNr_$eq, setLastSequenceNr, snapshotSequenceNr, snapshotterId, startRecovery, stash, stashInternally, super$aroundPostRestart, super$aroundPostStop, super$aroundPreRestart, super$aroundPreStart, super$aroundReceive, super$stash, super$unhandled, unhandled, unstashAll, unstashInternally, updateLastSequenceNr, waitingRecoveryPermit, writeEventFailed, writeEventRejected, writeEventSucceeded, writeInProgress_$eq

Methods inherited from interface org.apache.pekko.persistence.PersistenceIdentity

journalPluginId, persistenceId, snapshotPluginId

Methods inherited from interface org.apache.pekko.persistence.PersistenceRecovery

recovery

Methods inherited from interface org.apache.pekko.persistence.PersistenceStash

internalStashOverflowStrategy

Methods inherited from interface org.apache.pekko.persistence.Snapshotter

deleteSnapshot, deleteSnapshots, loadSnapshot, saveSnapshot

Methods inherited from interface org.apache.pekko.actor.StashFactory

createStash

Methods inherited from interface org.apache.pekko.actor.StashSupport

actorCell, clearStash, context, enqueueFirst, prepend, self, theStash_$eq, unstash, unstashAll

Methods inherited from interface org.apache.pekko.actor.Timers

actorCell, super$aroundPostStop, super$aroundPreRestart, super$aroundReceive, timers

Constructor Details

AbstractPersistentActorWithTimers

public AbstractPersistentActorWithTimers()

Method Details

aroundPostStop

protected void aroundPostStop()

Description copied from interface: Actor

INTERNAL API.

Can be overridden to intercept calls to postStop. Calls postStop by default.

Specified by:

aroundPostStop in interface Actor

Specified by:

aroundPostStop in interface Eventsourced

Specified by:

aroundPostStop in interface Timers

aroundPreRestart

protected void aroundPreRestart(Throwable reason,
 scala.Option<Object> message)

Description copied from interface: Actor

INTERNAL API.

Can be overridden to intercept calls to preRestart. Calls preRestart by default.

Specified by:

aroundPreRestart in interface Actor

Specified by:

aroundPreRestart in interface Eventsourced

Specified by:

aroundPreRestart in interface Timers

aroundReceive

protected void aroundReceive(scala.PartialFunction<Object,scala.runtime.BoxedUnit> receive,
 Object msg)

Description copied from interface: Actor

INTERNAL API.

Can be overridden to intercept calls to this actor's current behavior.

Specified by:

aroundReceive in interface Actor

Specified by:

aroundReceive in interface Eventsourced

Specified by:

aroundReceive in interface Timers

Parameters:

receive - current behavior.

msg - current message.

journal

protected ActorRef journal()

Specified by:

journal in interface Eventsourced

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

snapshotStore

protected ActorRef snapshotStore()

Description copied from interface: Snapshotter

Snapshot store plugin actor.

Specified by:

snapshotStore in interface Eventsourced

Specified by:

snapshotStore in interface Snapshotter