Package | Description |
---|---|
org.axonframework.config | |
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.serialization.upcasting.event |
Modifier and Type | Method and Description |
---|---|
Configurer |
DefaultConfigurer.registerEventUpcaster(Function<Configuration,EventUpcaster> upcasterBuilder) |
Configurer |
Configurer.registerEventUpcaster(Function<Configuration,EventUpcaster> upcasterBuilder)
Registers an upcaster to be used to upcast Events to a newer version
|
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 . |
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 . |
Constructor and Description |
---|
AbstractEventStorageEngine(Serializer serializer,
EventUpcaster upcasterChain,
PersistenceExceptionResolver persistenceExceptionResolver)
Deprecated.
The constructor which supplies an additional
Serializer for
events should be used. |
AbstractEventStorageEngine(Serializer snapshotSerializer,
EventUpcaster upcasterChain,
PersistenceExceptionResolver persistenceExceptionResolver,
Serializer eventSerializer)
Initializes an EventStorageEngine with given
serializer , upcasterChain and persistenceExceptionResolver . |
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,
Integer batchSize)
Initializes an EventStorageEngine with given
serializer , upcasterChain , persistenceExceptionResolver , eventSerializer and batchSize . |
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 . |
Constructor and Description |
---|
JdbcEventStorageEngine(Serializer serializer,
EventUpcaster upcasterChain,
PersistenceExceptionResolver persistenceExceptionResolver,
ConnectionProvider connectionProvider,
TransactionManager transactionManager)
Initializes an EventStorageEngine that uses JDBC to store and load events using the default
EventSchema . |
JdbcEventStorageEngine(Serializer snapshotSerializer,
EventUpcaster upcasterChain,
PersistenceExceptionResolver persistenceExceptionResolver,
Serializer eventSerializer,
ConnectionProvider connectionProvider,
TransactionManager transactionManager)
Initializes an EventStorageEngine that uses JDBC to store and load events using the default
EventSchema . |
JdbcEventStorageEngine(Serializer snapshotSerializer,
EventUpcaster upcasterChain,
PersistenceExceptionResolver persistenceExceptionResolver,
Serializer eventSerializer,
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.
|
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.
|
Constructor and Description |
---|
JpaEventStorageEngine(Serializer serializer,
EventUpcaster upcasterChain,
DataSource dataSource,
EntityManagerProvider entityManagerProvider,
TransactionManager transactionManager)
Initializes an EventStorageEngine that uses JPA to store and load events.
|
JpaEventStorageEngine(Serializer snapshotSerializer,
EventUpcaster upcasterChain,
DataSource dataSource,
Serializer eventSerializer,
EntityManagerProvider entityManagerProvider,
TransactionManager transactionManager)
Initializes an EventStorageEngine that uses JPA to store and load events.
|
JpaEventStorageEngine(Serializer serializer,
EventUpcaster upcasterChain,
PersistenceExceptionResolver persistenceExceptionResolver,
EntityManagerProvider entityManagerProvider,
TransactionManager transactionManager)
Initializes an EventStorageEngine that uses JPA to store and load events.
|
JpaEventStorageEngine(Serializer snapshotSerializer,
EventUpcaster upcasterChain,
PersistenceExceptionResolver persistenceExceptionResolver,
Serializer eventSerializer,
EntityManagerProvider entityManagerProvider,
TransactionManager transactionManager)
Initializes an EventStorageEngine that uses JPA to store and load events.
|
JpaEventStorageEngine(Serializer snapshotSerializer,
EventUpcaster upcasterChain,
PersistenceExceptionResolver persistenceExceptionResolver,
Serializer eventSerializer,
Integer batchSize,
EntityManagerProvider entityManagerProvider,
TransactionManager transactionManager,
Long lowestGlobalSequence,
Integer maxGapOffset,
boolean explicitFlush)
Initializes an EventStorageEngine that uses JPA to store and load events.
|
Constructor and Description |
---|
MongoEventStorageEngine(Serializer serializer,
EventUpcaster upcasterChain,
Integer batchSize,
MongoTemplate template,
StorageStrategy storageStrategy)
Initializes an EventStorageEngine that uses Mongo to store and load events.
|
MongoEventStorageEngine(Serializer serializer,
EventUpcaster upcasterChain,
MongoTemplate template,
StorageStrategy storageStrategy)
Initializes an EventStorageEngine that uses Mongo to store and load events.
|
MongoEventStorageEngine(Serializer snapshotSerializer,
EventUpcaster upcasterChain,
PersistenceExceptionResolver persistenceExceptionResolver,
Serializer eventSerializer,
Integer batchSize,
MongoTemplate template,
StorageStrategy storageStrategy)
Initializes an EventStorageEngine that uses Mongo to store and load events.
|
MongoEventStorageEngine(Serializer snapshotSerializer,
EventUpcaster upcasterChain,
Serializer eventSerializer,
Integer batchSize,
MongoTemplate template,
StorageStrategy storageStrategy)
Initializes an EventStorageEngine that uses Mongo to store and load events.
|
MongoEventStorageEngine(Serializer snapshotSerializer,
EventUpcaster upcasterChain,
Serializer eventSerializer,
MongoTemplate template,
StorageStrategy storageStrategy)
Initializes an EventStorageEngine that uses Mongo to store and load events.
|
Modifier and Type | Class and Description |
---|---|
class |
ContextAwareEventMultiUpcaster<C>
Abstract implementation of a
SingleEntryMultiUpcaster and an EventUpcaster that eases the common
process of upcasting one intermediate event representation to several other representations by applying a flat
mapping function to the input stream of intermediate representations. |
class |
ContextAwareSingleEventUpcaster<C>
Abstract implementation of an event
Upcaster that eases the common process of upcasting one intermediate
event representation to another representation by applying a simple mapping function to the input stream of
intermediate representations. |
class |
EventMultiUpcaster
Abstract implementation of a
SingleEntryMultiUpcaster and an EventUpcaster that eases the common process of
upcasting one intermediate event representation to several other representations by applying a flat mapping function
to the input stream of intermediate representations. |
class |
EventUpcasterChain
Upcaster chain used to upcast
event representations . |
class |
NoOpEventUpcaster
Event upcaster that does nothing.
|
class |
SingleEventUpcaster
Abstract implementation of an event
Upcaster that eases the common process of upcasting one intermediate
event representation to another representation by applying a simple mapping function to the input stream of
intermediate representations. |
Constructor and Description |
---|
EventUpcasterChain(EventUpcaster... upcasters)
Initializes an upcaster chain from one or more upcasters.
|
Constructor and Description |
---|
EventUpcasterChain(List<? extends EventUpcaster> upcasters)
Initializes an upcaster chain from the given list of upcasters.
|
Copyright © 2010–2018. All rights reserved.