Optional aggregate id.
Returns the command BehaviorContext.
Returns an command BehaviorContext that doesn't allow event handler behavior changes.
Event log actor.
Java API of aggregateId.
Java API of lastEmitterAggregateId.
Global unique actor id.
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.
Java API of the command handler.
Collects processed events generated by
Java API of event-processing handler.
Java API of readFailure.
Java API of readSuccess.
Java API of the recovery handler.
Recovery completion handler.
Java API of the snapshot 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
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
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
Java API that sets this actor's command handler.
Java API that sets this actor's event handler.
Java API that sets this actor's event-processing handler.
This actor's event processing handler.
Java API that sets this actor's recovery handler.
Java API that sets this actor's snapshot handler.
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