| 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.