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 |
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.
|
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. |
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 . |
Constructor and Description |
---|
TrackedDomainEventData(TrackingToken trackingToken,
DomainEventData<T> domainEventEntry)
Initialize the TrackingDomainEventData with given
trackingToken and domainEventEntry . |
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 Optional<? extends DomainEventData<?>> |
JdbcEventStorageEngine.readSnapshotData(String aggregateIdentifier) |
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 Optional<? extends DomainEventData<?>> |
JpaEventStorageEngine.readSnapshotData(String aggregateIdentifier) |
Modifier and Type | Method and Description |
---|---|
protected abstract DomainEventData<?> |
AbstractMongoEventStorageStrategy.extractSnapshot(org.bson.Document object)
Retrieves snapshot event data from the given Mongo
object . |
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) |
Modifier and Type | Method and Description |
---|---|
protected DomainEventData<?> |
DocumentPerCommitStorageStrategy.extractSnapshot(org.bson.Document object) |
Modifier and Type | Method and Description |
---|---|
protected Stream<? extends DomainEventData<?>> |
DocumentPerCommitStorageStrategy.extractEvents(org.bson.Document object) |
Modifier and Type | Class and Description |
---|---|
class |
EventEntry
Implementation of a serialized event message that can be used to create a Mongo document.
|
Modifier and Type | Method and Description |
---|---|
protected DomainEventData<?> |
DocumentPerEventStorageStrategy.extractSnapshot(org.bson.Document object) |
Modifier and Type | Method and Description |
---|---|
protected Stream<? extends DomainEventData<?>> |
DocumentPerEventStorageStrategy.extractEvents(org.bson.Document object) |
Copyright © 2010–2018. All rights reserved.