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 |
Modifier and Type | Class and Description |
---|---|
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 TrackedEventData<?>> |
BatchingEventStorageEngine.fetchTrackedEvents(TrackingToken lastToken,
int batchSize)
Returns a batch of serialized event data entries in the event storage that have a
TrackingToken greater
than the given lastToken . |
protected Stream<? extends TrackedEventData<?>> |
BatchingEventStorageEngine.readEventData(TrackingToken trackingToken,
boolean mayBlock)
Returns a global
Stream containing all serialized event data entries in the event storage that have a
TrackingToken greater than the given trackingToken . |
protected abstract Stream<? extends TrackedEventData<?>> |
AbstractEventStorageEngine.readEventData(TrackingToken trackingToken,
boolean mayBlock)
Returns a global
Stream containing all serialized event data entries in the event storage that have a
TrackingToken greater than the given trackingToken . |
Modifier and Type | Method and Description |
---|---|
static Stream<TrackedEventMessage<?>> |
EventUtils.upcastAndDeserializeTrackedEvents(Stream<? extends TrackedEventData<?>> eventEntryStream,
Serializer serializer,
EventUpcaster upcasterChain,
boolean skipUnknownTypes)
Upcasts and deserializes the given
eventEntryStream using the given serializer and
upcasterChain . |
Modifier and Type | Method and Description |
---|---|
protected TrackedEventData<?> |
JdbcEventStorageEngine.getTrackedEventData(ResultSet resultSet,
GapAwareTrackingToken previousToken)
Extracts the next tracked event entry from the given
resultSet . |
Modifier and Type | Method and Description |
---|---|
protected List<? extends TrackedEventData<?>> |
JdbcEventStorageEngine.fetchTrackedEvents(TrackingToken lastToken,
int batchSize) |
Modifier and Type | Method and Description |
---|---|
protected List<? extends TrackedEventData<?>> |
JpaEventStorageEngine.fetchTrackedEvents(TrackingToken lastToken,
int batchSize) |
Modifier and Type | Method and Description |
---|---|
protected List<? extends TrackedEventData<?>> |
MongoEventStorageEngine.fetchTrackedEvents(TrackingToken lastToken,
int batchSize) |
List<? extends TrackedEventData<?>> |
StorageStrategy.findTrackedEvents(com.mongodb.client.MongoCollection<org.bson.Document> eventCollection,
TrackingToken lastToken,
int batchSize)
Returns a batch of tracked events with a tracking token above the given
lastToken . |
List<? extends TrackedEventData<?>> |
AbstractMongoEventStorageStrategy.findTrackedEvents(com.mongodb.client.MongoCollection<org.bson.Document> eventCollection,
TrackingToken lastToken,
int batchSize) |
Copyright © 2010–2018. All rights reserved.