Package | Description |
---|---|
org.axonframework.axonserver.connector.event.axon | |
org.axonframework.eventhandling |
Classes related to event handling and dispatching, such as
Event Listeners and the Event Bus . |
org.axonframework.eventsourcing |
Classes related to event sourcing.
|
org.axonframework.eventsourcing.eventstore |
Definitions and implementations of the Event store, the mechanism that can load event streams and append events to
them.
|
org.axonframework.eventsourcing.eventstore.jdbc |
JDBC Implementation of the EventStore.
|
org.axonframework.eventsourcing.eventstore.jpa |
JPA Implementation of the EventStore.
|
org.axonframework.eventsourcing.eventstore.legacyjpa | |
org.axonframework.eventsourcing.snapshotting |
Modifier and Type | Class and Description |
---|---|
class |
GrpcBackedDomainEventData
DomainEventData implementation that retrieves its raw data from a protobuf
Event message. |
Modifier and Type | Method and Description |
---|---|
AxonServerEventStore.Builder |
AxonServerEventStore.Builder.snapshotFilter(Predicate<? super DomainEventData<?>> snapshotFilter)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractDomainEventEntry<T>
Abstract base class of a serialized domain event.
|
class |
AbstractSequencedDomainEventEntry<T>
Abstract base class of a serialized domain event.
|
class |
GenericDomainEventEntry<T>
Generic implementation of a serialized domain event entry.
|
class |
TrackedDomainEventData<T>
Specialization of the DomainEventData class that includes the Token representing the position of this event in
a stream.
|
Constructor and Description |
---|
TrackedDomainEventData(TrackingToken trackingToken,
DomainEventData<T> domainEventEntry)
Initialize the TrackingDomainEventData with given
trackingToken and domainEventEntry . |
Modifier and Type | Method and Description |
---|---|
static DomainEventStream |
EventStreamUtils.upcastAndDeserializeDomainEvents(Stream<? extends DomainEventData<?>> eventEntryStream,
Serializer serializer,
EventUpcaster upcasterChain)
Upcasts and deserializes the given
eventEntryStream using the given serializer and
upcasterChain . |
Modifier and Type | Class and Description |
---|---|
class |
AbstractSnapshotEventEntry<T>
Abstract base class of a serialized snapshot event storing the state of an aggregate.
|
Modifier and Type | Method and Description |
---|---|
protected abstract List<? extends DomainEventData<?>> |
BatchingEventStorageEngine.fetchDomainEvents(String aggregateIdentifier,
long firstSequenceNumber,
int batchSize)
Returns a batch of events published by an aggregate with given
aggregateIdentifier . |
protected Stream<? extends DomainEventData<?>> |
BatchingEventStorageEngine.readEventData(String identifier,
long firstSequenceNumber) |
protected abstract Stream<? extends DomainEventData<?>> |
AbstractEventStorageEngine.readEventData(String identifier,
long firstSequenceNumber)
Returns a
Stream of serialized event data entries for an aggregate with given identifier . |
protected abstract Stream<? extends DomainEventData<?>> |
AbstractEventStorageEngine.readSnapshotData(String aggregateIdentifier)
Returns a stream of serialized event entries for given
aggregateIdentifier if the backing database
contains a snapshot of the aggregate. |
Modifier and Type | Method and Description |
---|---|
boolean |
EqualRevisionPredicate.test(DomainEventData<?> snapshot) |
Modifier and Type | Method and Description |
---|---|
BatchingEventStorageEngine.Builder |
BatchingEventStorageEngine.Builder.finalAggregateBatchPredicate(Predicate<List<? extends DomainEventData<?>>> finalAggregateBatchPredicate)
Defines the predicate to use to recognize the terminal batch when reading an event stream for an aggregate.
|
BatchingEventStorageEngine.Builder |
BatchingEventStorageEngine.Builder.snapshotFilter(Predicate<? super DomainEventData<?>> snapshotFilter)
Deprecated.
|
AbstractEventStorageEngine.Builder |
AbstractEventStorageEngine.Builder.snapshotFilter(Predicate<? super DomainEventData<?>> snapshotFilter)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected DomainEventData<?> |
JdbcEventStorageEngine.getDomainEventData(ResultSet resultSet)
Extracts the next domain event entry from the given
resultSet . |
protected DomainEventData<?> |
JdbcEventStorageEngine.getSnapshotData(ResultSet resultSet)
Extracts the next snapshot entry from the given
resultSet . |
Modifier and Type | Method and Description |
---|---|
protected List<? extends DomainEventData<?>> |
JdbcEventStorageEngine.fetchDomainEvents(String aggregateIdentifier,
long firstSequenceNumber,
int batchSize) |
protected Stream<? extends DomainEventData<?>> |
JdbcEventStorageEngine.readSnapshotData(String aggregateIdentifier) |
Modifier and Type | Method and Description |
---|---|
JdbcEventStorageEngine.Builder |
JdbcEventStorageEngine.Builder.finalAggregateBatchPredicate(Predicate<List<? extends DomainEventData<?>>> finalAggregateBatchPredicate)
Defines the predicate to use to recognize the terminal batch when reading an event stream for an aggregate.
|
JdbcEventStorageEngine.Builder |
JdbcEventStorageEngine.Builder.snapshotFilter(Predicate<? super DomainEventData<?>> snapshotFilter)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
DomainEventEntry
Default implementation of a tracked domain event entry.
|
class |
SnapshotEventEntry
Default implementation of an event entry containing a serialized snapshot of an aggregate.
|
Modifier and Type | Method and Description |
---|---|
protected List<? extends DomainEventData<?>> |
JpaEventStorageEngine.fetchDomainEvents(String aggregateIdentifier,
long firstSequenceNumber,
int batchSize) |
protected Stream<? extends DomainEventData<?>> |
JpaEventStorageEngine.readSnapshotData(String aggregateIdentifier) |
Modifier and Type | Method and Description |
---|---|
JpaEventStorageEngine.Builder |
JpaEventStorageEngine.Builder.finalAggregateBatchPredicate(Predicate<List<? extends DomainEventData<?>>> finalAggregateBatchPredicate)
Defines the predicate to use to recognize the terminal batch when reading an event stream for an aggregate.
|
JpaEventStorageEngine.Builder |
JpaEventStorageEngine.Builder.snapshotFilter(Predicate<? super DomainEventData<?>> snapshotFilter)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected List<? extends DomainEventData<?>> |
JpaEventStorageEngine.fetchDomainEvents(String aggregateIdentifier,
long firstSequenceNumber,
int batchSize)
Deprecated.
|
protected Stream<? extends DomainEventData<?>> |
JpaEventStorageEngine.readSnapshotData(String aggregateIdentifier)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
JpaEventStorageEngine.Builder |
JpaEventStorageEngine.Builder.finalAggregateBatchPredicate(Predicate<List<? extends DomainEventData<?>>> finalAggregateBatchPredicate)
Defines the predicate to use to recognize the terminal batch when reading an event stream for an aggregate.
|
JpaEventStorageEngine.Builder |
JpaEventStorageEngine.Builder.snapshotFilter(Predicate<? super DomainEventData<?>> snapshotFilter)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
default boolean |
SnapshotFilter.allow(DomainEventData<?> snapshotData)
Function applied to filter out snapshot data in the form of a
DomainEventData . |
boolean |
RevisionSnapshotFilter.test(DomainEventData<?> domainEventData) |
Copyright © 2010–2024. All rights reserved.