Java API for actors that implement EventsourcedActor.
Java API for actors that implement EventsourcedProcessor.
Java API for actors that implement StatefulProcessor.
Java API for actors that implement EventsourcedView.
Java API for actors that implement EventsourcedWriter.
Defines an application version in terms of
major version and
Provides a context for managing behaviors.
A ReplicationFilter that can be used in combination with com.rbmhtechnology.eventuate.serializer.DurableEventSerializerWithBinaryPayload.
Tracks concurrent Versioned values which arise from concurrent updates.
Versioned value type
A ConcurrentVersions implementation that shall be used if updates replace current versioned values (= full updates).
A ConcurrentVersions implementation that shall be used if updates are incremental.
A conditional request is a request to an actor in the EventsourcedView
hierarchy whose delivery to the actor's command handler is delayed until
condition is in the causal past of that actor (i.e.
Supports the reliable delivery of messages to destinations by enabling applications to redeliver messages until they are confirmed by their destinations.
Aggregate id of emitter (EventsourcedActor or EventsourcedProcessor). This is also
the default routing destination of this event. If defined, the event is routed to event-
sourced actors, views, writers and processors with a matching
aggregateId. In any case,
the event is routed to event-sourced actors, views, writers and processors with an undefined
Aggregate ids of additional, custom routing destinations. If non-empty, the event is
additionally routed to event-sourced actors, views, writers and processors with a
Wall-clock timestamp, generated by the source of concurrent activity that is identified by
Vector timestamp, generated by the source of concurrent activity that is identified by
Id of the causality-tracking source of concurrent activity. This is the id of the local event log that initially wrote the event.
Id of the local event log.
Sequence number in the local event log.
Delivery id chosen by an application that persisted this event with ConfirmedDelivery.persistConfirmation.
Sequence number of the event that caused the emission of this event in an event handler.
Defined if an EventsourcedActor with a PersistOnEvent mixin emitted this event
persistOnEvent. Actually superseded by
persistOnEventId, but still
has to be maintained for backwards compatibility. It is required for confirmation
of old com.rbmhtechnology.eventuate.PersistOnEvent.PersistOnEventRequests from
a snapshot that do not have com.rbmhtechnology.eventuate.PersistOnEvent.PersistOnEventRequest.persistOnEventId
Implemented by protocol messages that contain a DurableEvent sequence.
Unique id of a DurableEvent.
the id of the event log the initially wrote the event.
the initial sequence number in this log.
EventsourcedActor is an EventsourcedView that can also write new events to its event log.
An EventsourcedWriter that writes processed events to a
Maintains the current version of an event-sourced component.
An actor that derives internal state from events stored in an event log.
An EventsourcedView designed to update external databases from events stored in its event log.
Can be mixed into EventsourcedActor for writing new events within the
Thrown to indicate that an asynchronous
persisOnEvent operation failed.
ReplicationEndpoint.recover completes with this exception if recovery fails.
A replication connection descriptor.
A replication endpoint connects to other replication endpoints for replicating events.
Serializable and composable replication filter.
Java API handler that accepts a success and a failure function.
type of the result object
Id of the event-sourced actor, view, stateful writer or processor that saved the snapshot.
Last handled event before the snapshot was saved.
Current vector time when the snapshot was saved.
Sequence number of the last *received* event when the snapshot was saved.
Unconfirmed PersistOnEventRequests when the snapshot was saved (can only be non-empty if the actor implements PersistOnEvent).
Thrown to indicate that a
stash() operation was used at an illegal location.
An EventsourcedProcessor that supports stateful event processing.
Implemented by protocol messages whose event sequence can be updated.
Vector time, represented as process id -> logical time map.
A versioned value.
Update vector timestamp of the event that caused this version.
Update system timestamp of the event that caused this version.
Creator of the event that caused this version.
Manages concurrent versions of an event-sourced aggregate.