Uses of Interface
org.axonframework.eventsourcing.eventstore.DomainEventData

Packages that use DomainEventData

Package	Description
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.mongo.eventsourcing.eventstore
org.axonframework.mongo.eventsourcing.eventstore.documentpercommit
org.axonframework.mongo.eventsourcing.eventstore.documentperevent

Uses of DomainEventData in org.axonframework.eventsourcing.eventstore

Classes in org.axonframework.eventsourcing.eventstore that implement DomainEventData

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	AbstractSnapshotEventEntry<T> Abstract base class of a serialized snapshot event storing the state of an aggregate.
class	GenericDomainEventEntry<T> Generic implementation of a serialized domain event entry.
class	GenericTrackedDomainEventEntry<T> Deprecated. Use TrackedDomainEventData instead, as it uses composition (instead of inheritance)
class	TrackedDomainEventData<T> Specialization of the DomainEventData class that includes the Token representing the position of this event in a stream.

Methods in org.axonframework.eventsourcing.eventstore that return types with arguments of type DomainEventData

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 Optional<? extends DomainEventData<?>>	AbstractEventStorageEngine.readSnapshotData(String aggregateIdentifier) Returns an optional serialized event entry for given aggregateIdentifier if the backing database contains a snapshot of the aggregate.

Methods in org.axonframework.eventsourcing.eventstore with parameters of type DomainEventData

Modifier and Type	Method and Description
boolean	EqualRevisionPredicate.test(DomainEventData<?> snapshot)

Method parameters in org.axonframework.eventsourcing.eventstore with type arguments of type DomainEventData

Modifier and Type	Method and Description
static DomainEventStream	EventUtils.upcastAndDeserializeDomainEvents(Stream<? extends DomainEventData<?>> eventEntryStream, Serializer serializer, EventUpcaster upcasterChain, boolean skipUnknownTypes) Upcasts and deserializes the given eventEntryStream using the given serializer and upcasterChain.

Constructors in org.axonframework.eventsourcing.eventstore with parameters of type DomainEventData

Constructor and Description
TrackedDomainEventData(TrackingToken trackingToken, DomainEventData<T> domainEventEntry) Initialize the TrackingDomainEventData with given trackingToken and domainEventEntry.

Constructor parameters in org.axonframework.eventsourcing.eventstore with type arguments of type DomainEventData

Constructor and Description
AbstractEventStorageEngine(Serializer snapshotSerializer, EventUpcaster upcasterChain, PersistenceExceptionResolver persistenceExceptionResolver, Serializer eventSerializer, Predicate<? super DomainEventData<?>> snapshotFilter) Initializes an EventStorageEngine with given serializer, upcasterChain and persistenceExceptionResolver.
BatchingEventStorageEngine(Serializer snapshotSerializer, EventUpcaster upcasterChain, PersistenceExceptionResolver persistenceExceptionResolver, Serializer eventSerializer, Predicate<? super DomainEventData<?>> snapshotFilter, Integer batchSize) Initializes an EventStorageEngine with given serializer, upcasterChain, persistenceExceptionResolver, eventSerializer and batchSize.

Uses of DomainEventData in org.axonframework.eventsourcing.eventstore.jdbc

Methods in org.axonframework.eventsourcing.eventstore.jdbc that return DomainEventData

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.

Methods in org.axonframework.eventsourcing.eventstore.jdbc that return types with arguments of type DomainEventData

Modifier and Type	Method and Description
protected List<? extends DomainEventData<?>>	JdbcEventStorageEngine.fetchDomainEvents(String aggregateIdentifier, long firstSequenceNumber, int batchSize)
protected Optional<? extends DomainEventData<?>>	JdbcEventStorageEngine.readSnapshotData(String aggregateIdentifier)

Constructor parameters in org.axonframework.eventsourcing.eventstore.jdbc with type arguments of type DomainEventData

Constructor and Description

JdbcEventStorageEngine(Serializer snapshotSerializer, EventUpcaster upcasterChain, PersistenceExceptionResolver persistenceExceptionResolver, Serializer eventSerializer, Predicate<? super DomainEventData<?>> snapshotFilter, Integer batchSize, ConnectionProvider connectionProvider, TransactionManager transactionManager, Class<?> dataType, EventSchema schema, Integer maxGapOffset, Long lowestGlobalSequence) Initializes an EventStorageEngine that uses JDBC to store and load events.

Uses of DomainEventData in org.axonframework.eventsourcing.eventstore.jpa

Classes in org.axonframework.eventsourcing.eventstore.jpa that implement DomainEventData

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.

Methods in org.axonframework.eventsourcing.eventstore.jpa that return types with arguments of type DomainEventData

Modifier and Type	Method and Description
protected List<? extends DomainEventData<?>>	JpaEventStorageEngine.fetchDomainEvents(String aggregateIdentifier, long firstSequenceNumber, int batchSize)
protected Optional<? extends DomainEventData<?>>	JpaEventStorageEngine.readSnapshotData(String aggregateIdentifier)

Uses of DomainEventData in org.axonframework.mongo.eventsourcing.eventstore

Methods in org.axonframework.mongo.eventsourcing.eventstore that return DomainEventData

Modifier and Type	Method and Description
protected abstract DomainEventData<?>	AbstractMongoEventStorageStrategy.extractSnapshot(org.bson.Document object) Retrieves snapshot event data from the given Mongo object.

Methods in org.axonframework.mongo.eventsourcing.eventstore that return types with arguments of type DomainEventData

Modifier and Type	Method and Description
protected abstract Stream<? extends DomainEventData<?>>	AbstractMongoEventStorageStrategy.extractEvents(org.bson.Document object) Retrieves event data from the given Mongo object.
protected List<? extends DomainEventData<?>>	MongoEventStorageEngine.fetchDomainEvents(String aggregateIdentifier, long firstSequenceNumber, int batchSize)
List<? extends DomainEventData<?>>	StorageStrategy.findDomainEvents(com.mongodb.client.MongoCollection<org.bson.Document> eventCollection, String aggregateIdentifier, long firstSequenceNumber, int batchSize) Returns a batch of events for an aggregate with given aggregateIdentifier and a sequence number equal or higher than the given firstSequenceNumber.
List<? extends DomainEventData<?>>	AbstractMongoEventStorageStrategy.findDomainEvents(com.mongodb.client.MongoCollection<org.bson.Document> collection, String aggregateIdentifier, long firstSequenceNumber, int batchSize)
Optional<? extends DomainEventData<?>>	StorageStrategy.findLastSnapshot(com.mongodb.client.MongoCollection<org.bson.Document> snapshotCollection, String aggregateIdentifier) Finds the entry containing the last snapshot event for an aggregate with given aggregateIdentifier in the given collection.
Optional<? extends DomainEventData<?>>	AbstractMongoEventStorageStrategy.findLastSnapshot(com.mongodb.client.MongoCollection<org.bson.Document> snapshotCollection, String aggregateIdentifier)
protected Optional<? extends DomainEventData<?>>	MongoEventStorageEngine.readSnapshotData(String aggregateIdentifier)

Uses of DomainEventData in org.axonframework.mongo.eventsourcing.eventstore.documentpercommit

Methods in org.axonframework.mongo.eventsourcing.eventstore.documentpercommit that return DomainEventData

Modifier and Type	Method and Description
protected DomainEventData<?>	DocumentPerCommitStorageStrategy.extractSnapshot(org.bson.Document object)

Methods in org.axonframework.mongo.eventsourcing.eventstore.documentpercommit that return types with arguments of type DomainEventData

Modifier and Type	Method and Description
protected Stream<? extends DomainEventData<?>>	DocumentPerCommitStorageStrategy.extractEvents(org.bson.Document object)

Uses of DomainEventData in org.axonframework.mongo.eventsourcing.eventstore.documentperevent

Classes in org.axonframework.mongo.eventsourcing.eventstore.documentperevent that implement DomainEventData

Modifier and Type	Class and Description
class	EventEntry Implementation of a serialized event message that can be used to create a Mongo document.

Methods in org.axonframework.mongo.eventsourcing.eventstore.documentperevent that return DomainEventData

Modifier and Type	Method and Description
protected DomainEventData<?>	DocumentPerEventStorageStrategy.extractSnapshot(org.bson.Document object)

Methods in org.axonframework.mongo.eventsourcing.eventstore.documentperevent that return types with arguments of type DomainEventData

Modifier and Type	Method and Description
protected Stream<? extends DomainEventData<?>>	DocumentPerEventStorageStrategy.extractEvents(org.bson.Document object)