akka.persistence
Class UntypedEventsourcedProcessor

java.lang.Object
  akka.actor.UntypedActor
      akka.persistence.UntypedPersistentActor
          akka.persistence.UntypedEventsourcedProcessor

All Implemented Interfaces:

Actor, Stash, StashFactory, StashSupport, UnrestrictedStash, RequiresMessageQueue<DequeBasedMessageQueueSemantics>, Eventsourced, ProcessorImpl, Recovery, Snapshotter

public abstract class UntypedEventsourcedProcessor
extends UntypedPersistentActor

Java API: an event sourced processor.

Nested Class Summary

Nested classes/interfaces inherited from interface akka.persistence.Eventsourced

Eventsourced.PendingHandlerInvocation

Nested classes/interfaces inherited from interface akka.persistence.Recovery

Recovery.State

Nested classes/interfaces inherited from interface akka.actor.Actor

Actor.emptyBehavior$

Constructor Summary

UntypedEventsourcedProcessor()

Method Summary

java.lang.String

persistenceId() Id of the persistent entity for which messages should be replayed.

Methods inherited from class akka.persistence.UntypedPersistentActor

defer, defer, onReceive, onReceiveCommand, onReceiveRecover, persist, persist, persistAsync, persistAsync, receiveCommand, receiveRecover

Methods inherited from class akka.actor.UntypedActor

getContext, getSelf, getSender, postRestart, postStop, preRestart, preStart, receive, supervisorStrategy, unhandled

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.persistence.Eventsourced

aroundPreRestart, aroundReceive, currentState, defer, defer, flushBatch, initialBehavior, pendingInvocations, pendingStashingPersistInvocations, persist, persist, persistAsync, persistAsync, persistingEvents, postStop, preRestart, processingCommands, processorStash, recovering, recoveryBehavior, resequenceableEventBatch, unstashAll, useProcessorBatching

Methods inherited from interface akka.persistence.ProcessorImpl

_persistenceId, aroundPostStop, aroundPreStart, deleteMessage, deleteMessage, deleteMessages, deleteMessages, flushJournalBatch, initializing, instanceId, nextSequenceNr, onRecoveryCompleted, onRecoveryFailure, onReplayFailure, onReplaySuccess, preRestartDefault, preStart, processing, processorBatch, processorId, recoveryFinished, recoveryRunning, sequenceNr, snapshotterId, unhandled, unstashFilterPredicate

Methods inherited from interface akka.persistence.Recovery

_currentPersistent, _currentState, _lastSequenceNr, _recoveryFailureCause, _recoveryFailureMessage, currentPersistentMessage, extension, getCurrentPersistentMessage, journal, lastSequenceNr, prepareRestart, receiverStash, recoveryPending, recoveryStarted, replayFailed, replayStarted, runReceive, snapshotSequenceNr, updateLastSequenceNr, updateLastSequenceNr, withCurrentPersistent

Methods inherited from interface akka.persistence.Snapshotter

deleteSnapshot, deleteSnapshots, loadSnapshot, saveSnapshot, snapshotStore

Methods inherited from interface akka.actor.Actor

aroundPostRestart, context, postRestart, receive, self, sender, supervisorStrategy

Methods inherited from interface akka.actor.StashSupport

actorCell, capacity, clearStash, context, enqueueFirst, mailbox, prepend, self, stash, theStash, unstash, unstashAll

Methods inherited from interface akka.actor.StashFactory

createStash

Constructor Detail

UntypedEventsourcedProcessor

public UntypedEventsourcedProcessor()

Method Detail

persistenceId

public java.lang.String persistenceId()

Description copied from interface: Recovery

Id of the persistent entity for which messages should be replayed.

Returns:

(undocumented)