Package | Description |
---|---|
org.axonframework.eventhandling |
Classes related to event handling and dispatching, such as
Event Listeners and the Event Bus . |
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.
|
Modifier and Type | Class and Description |
---|---|
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 |
---|---|
static Stream<TrackedEventMessage<?>> |
EventUtils.upcastAndDeserializeTrackedEvents(Stream<? extends TrackedEventData<?>> eventEntryStream,
Serializer serializer,
EventUpcaster upcasterChain)
Upcasts and deserializes the given
eventEntryStream using the given serializer and
upcasterChain . |
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 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 . |
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 . |
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) |
Copyright © 2010–2019. All rights reserved.