|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.actor.AbstractActor akka.persistence.AbstractPersistentActor akka.persistence.AbstractEventsourcedProcessor
public abstract class AbstractEventsourcedProcessor
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 |
---|
public AbstractEventsourcedProcessor()
Method Detail |
---|
public java.lang.String persistenceId()
Recovery
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |