akka.persistence
Class AbstractEventsourcedProcessor

java.lang.Object
  extended by akka.actor.AbstractActor
      extended by akka.persistence.AbstractPersistentActor
          extended by 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)