akka.persistence
Class AbstractEventsourcedProcessor

java.lang.Object
  akka.actor.AbstractActor
      akka.persistence.AbstractPersistentActor
          akka.persistence.AbstractEventsourcedProcessor

All Implemented Interfaces:

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

public abstract class AbstractEventsourcedProcessor
extends AbstractPersistentActor

Java API: compatible with lambda expressions (to be used with ReceiveBuilder): 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. Commands sent to event sourced processors must not be Persistent or PersistentBatch messages. In this case an UnsupportedOperationException is thrown by the 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

AbstractEventsourcedProcessor()

Method Summary

java.lang.String

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

Methods inherited from class akka.persistence.AbstractPersistentActor

defer, defer, persist, persist, persistAsync, persistAsync, receive

Methods inherited from class akka.actor.AbstractActor

emptyBehavior, getContext, receive

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, receiveCommand, receiveRecover, 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, 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

AbstractEventsourcedProcessor

public AbstractEventsourcedProcessor()

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)