Optional aggregate id.
Returns the command BehaviorContext.
Java API of the command handler.
Java API of event-processing handler.
Java API of the recovery handler.
Java API of the snapshot handler.
Returns an command BehaviorContext that doesn't allow event handler behavior changes.
Event log actor.
Java API of aggregateId.
Java API of commandContext.
Returns this AbstractActor's ActorContext.
Java API of eventContext.
Java API of lastEmitterAggregateId.
Java API of lastEmitterId.
Java API of lastSequenceNr.
Java API of lastSystemTimestamp.
Java API of lastVectorTimestamp.
Returns the ActorRef for this actor.
The reference sender Actor of the currently processed message.
Java API of snapshotContext.
Global unique actor id.
Java API of lastEmirecoveringterId.
Emitter aggregate id of the last handled event.
Emitter id of the last handled event.
Id of the local event log that initially wrote the event.
Sequence number of the last handled event.
Wall-clock timestamp of the last handled event.
Vector timestamp of the last handled event.
This actor's logging adapter.
Collects processed events generated by
Java API of readFailure.
Java API of readSuccess.
Recovery completion handler.
Java API of writeFailure.
Java API of writeSuccess.
Override to allow post-processing of DurableEvent instances wrapping events generated by
false before calling
false before calling
creates a new empty ProcessBuilder
Asynchronously reads the processing progress from the target event log.
Sets the read processing progress for this processor and returns it incremented by 1.
The default read timeout configured with the
Creates a new empty
true if this actor is currently recovering internal state by consuming
replayed events from the event log.
Maximum number of events to be replayed to this actor before replaying is suspended.
Disallow for EventsourcedWriter and subclasses as event processing progress is determined by
Java API of save.
Asynchronously saves the given
snapshot and calls
handler with the generated
Returns the snapshot BehaviorContext.
Adds the current command to the user's command stash.
This processor's target event log.
Prepends all stashed commands to the actor's mailbox and then clears the command stash.
Asynchronously writes processed events that have been collected since the last write together with the current processing progress.
The default write timeout configured with the