Package | Description |
---|---|
org.axonframework.commandhandling.conflictresolution | |
org.axonframework.commandhandling.disruptor | |
org.axonframework.config | |
org.axonframework.eventsourcing |
Classes related to event sourcing.
|
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.spring.eventsourcing | |
org.axonframework.test.aggregate |
Constructor and Description |
---|
DefaultConflictResolver(EventStore eventStore,
String aggregateIdentifier,
long expectedVersion,
long actualVersion)
Initializes a
DefaultConflictResolver using the given eventStore to load unseen events since
given expectedVersion . |
Modifier and Type | Method and Description |
---|---|
<T> Repository<T> |
DisruptorCommandBus.createRepository(EventStore eventStore,
AggregateFactory<T> aggregateFactory)
Creates a repository instance for an Event Sourced aggregate that is created by the given
eventStore and aggregateFactory . |
<T> Repository<T> |
DisruptorCommandBus.createRepository(EventStore eventStore,
AggregateFactory<T> aggregateFactory,
ParameterResolverFactory parameterResolverFactory)
Creates a repository instance for an Event Sourced aggregate that is created by the given
aggregateFactory and sourced from given eventStore . |
<T> Repository<T> |
DisruptorCommandBus.createRepository(EventStore eventStore,
AggregateFactory<T> aggregateFactory,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition,
RepositoryProvider repositoryProvider)
Creates a repository instance for an Event Sourced aggregate that is created by the given
aggregateFactory and sourced from given eventStore . |
<T> Repository<T> |
DisruptorCommandBus.createRepository(EventStore eventStore,
AggregateFactory<T> aggregateFactory,
RepositoryProvider repositoryProvider)
Creates a repository instance for an Event Sourced aggregate that is created by the given
eventStore and aggregateFactory . |
<T> Repository<T> |
DisruptorCommandBus.createRepository(EventStore eventStore,
AggregateFactory<T> aggregateFactory,
SnapshotTriggerDefinition snapshotTriggerDefinition)
Creates a repository instance for an Event Sourced aggregate, source from given
eventStore , that is
created by the given aggregateFactory . |
<T> Repository<T> |
DisruptorCommandBus.createRepository(EventStore eventStore,
AggregateFactory<T> aggregateFactory,
SnapshotTriggerDefinition snapshotTriggerDefinition,
ParameterResolverFactory parameterResolverFactory)
Creates a repository instance for an Event Sourced aggregate, sourced from given
eventStore , that is
created by the given aggregateFactory . |
<T> Repository<T> |
CommandHandlerInvoker.createRepository(EventStore eventStore,
AggregateFactory<T> aggregateFactory,
SnapshotTriggerDefinition snapshotTriggerDefinition,
ParameterResolverFactory parameterResolverFactory)
Create a repository instance for an aggregate created by the given
aggregateFactory . |
<T> Repository<T> |
DisruptorCommandBus.createRepository(EventStore eventStore,
AggregateFactory<T> aggregateFactory,
SnapshotTriggerDefinition snapshotTriggerDefinition,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition,
RepositoryProvider repositoryProvider)
Creates a repository instance for an Event Sourced aggregate, sourced from given
eventStore , that is
created by the given aggregateFactory . |
<T> Repository<T> |
DisruptorCommandBus.createRepository(EventStore eventStore,
AggregateFactory<T> aggregateFactory,
SnapshotTriggerDefinition snapshotTriggerDefinition,
RepositoryProvider repositoryProvider)
Creates a repository instance for an Event Sourced aggregate, source from given
eventStore , that is
created by the given aggregateFactory . |
<T> Repository<T> |
CommandHandlerInvoker.createRepository(EventStore eventStore,
RepositoryProvider repositoryProvider,
AggregateFactory<T> aggregateFactory,
SnapshotTriggerDefinition snapshotTriggerDefinition,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition)
Create a repository instance for an aggregate created by the given
aggregateFactory . |
Constructor and Description |
---|
DisruptorCommandBus(EventStore eventStore)
Deprecated.
Use
DisruptorCommandBus.DisruptorCommandBus() instead |
DisruptorCommandBus(EventStore eventStore,
DisruptorConfiguration configuration)
Deprecated.
Use
instead |
Modifier and Type | Method and Description |
---|---|
default EventStore |
Configuration.eventStore()
Returns the Event Store in this Configuration, if it is defined.
|
Modifier and Type | Method and Description |
---|---|
default Configurer |
Configurer.configureEventStore(Function<Configuration,EventStore> eventStoreBuilder)
Configures the given Event Store to use in this configuration.
|
Modifier and Type | Method and Description |
---|---|
protected EventStore |
AbstractSnapshotter.getEventStore()
Returns the event store this snapshotter uses to load domain events and store snapshot events.
|
Modifier and Type | Method and Description |
---|---|
EventSourcedAggregate<T> |
AggregateCacheEntry.recreateAggregate(AggregateModel<T> model,
EventStore eventStore,
RepositoryProvider repositoryProvider,
SnapshotTriggerDefinition snapshotTriggerDefinition) |
EventSourcedAggregate<T> |
AggregateCacheEntry.recreateAggregate(AggregateModel<T> model,
EventStore eventStore,
SnapshotTriggerDefinition snapshotTriggerDefinition) |
Constructor and Description |
---|
AbstractSnapshotter(EventStore eventStore)
Initializes the Snapshotter to append snapshots in the given
eventStore . |
AbstractSnapshotter(EventStore eventStore,
Executor executor,
TransactionManager transactionManager)
Initializes the Snapshotter to append snapshots in the given
eventStore . |
AbstractSnapshotter(EventStore eventStore,
TransactionManager transactionManager)
Initializes the Snapshotter to append snapshots in the given
eventStore . |
AggregateSnapshotter(EventStore eventStore,
AggregateFactory<?>... aggregateFactories)
Initializes a snapshotter using the ParameterResolverFactory instances available on the classpath.
|
AggregateSnapshotter(EventStore eventStore,
List<AggregateFactory<?>> aggregateFactories)
Initializes a snapshotter using the ParameterResolverFactory instances available on the classpath.
|
AggregateSnapshotter(EventStore eventStore,
List<AggregateFactory<?>> aggregateFactories,
ParameterResolverFactory parameterResolverFactory)
Initializes a snapshotter using the given
parameterResolverFactory . |
AggregateSnapshotter(EventStore eventStore,
List<AggregateFactory<?>> aggregateFactories,
ParameterResolverFactory parameterResolverFactory,
Executor executor,
TransactionManager transactionManager)
Initializes a snapshotter that stores snapshots using the given
executor . |
AggregateSnapshotter(EventStore eventStore,
List<AggregateFactory<?>> aggregateFactories,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition,
Executor executor,
TransactionManager transactionManager,
RepositoryProvider repositoryProvider)
Initializes a snapshotter that stores snapshots using the given
executor . |
AggregateSnapshotter(EventStore eventStore,
List<AggregateFactory<?>> aggregateFactories,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition,
RepositoryProvider repositoryProvider)
Initializes a snapshotter using the given
parameterResolverFactory . |
AggregateSnapshotter(EventStore eventStore,
List<AggregateFactory<?>> aggregateFactories,
RepositoryProvider repositoryProvider)
Initializes a snapshotter using the ParameterResolverFactory instances available on the classpath.
|
AggregateSnapshotter(EventStore eventStore,
RepositoryProvider repositoryProvider,
AggregateFactory<?>... aggregateFactories)
Initializes a snapshotter using the ParameterResolverFactory instances available on the classpath.
|
CachingEventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore,
Cache cache)
Initializes a repository with a the given
aggregateFactory and a pessimistic locking strategy. |
CachingEventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore,
Cache cache,
RepositoryProvider repositoryProvider)
Initializes a repository with a the given
aggregateFactory and a pessimistic locking strategy. |
CachingEventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore,
Cache cache,
SnapshotTriggerDefinition snapshotTriggerDefinition)
Initializes a repository with a the given
aggregateFactory and a pessimistic locking strategy. |
CachingEventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore,
Cache cache,
SnapshotTriggerDefinition snapshotTriggerDefinition,
RepositoryProvider repositoryProvider)
Initializes a repository with a the given
aggregateFactory and a pessimistic locking strategy. |
CachingEventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore,
LockFactory lockFactory,
Cache cache,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition,
SnapshotTriggerDefinition snapshotTriggerDefinition,
RepositoryProvider repositoryProvider)
Initializes a repository with a the given
aggregateFactory and a pessimistic locking strategy. |
CachingEventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore,
LockFactory lockFactory,
Cache cache,
ParameterResolverFactory parameterResolverFactory,
SnapshotTriggerDefinition snapshotTriggerDefinition)
Initializes a repository with a the given
aggregateFactory and a pessimistic locking strategy. |
CachingEventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore,
LockFactory lockFactory,
Cache cache,
SnapshotTriggerDefinition snapshotTriggerDefinition)
Initializes a repository with a the given
aggregateFactory and a pessimistic locking strategy. |
CachingEventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore,
LockFactory lockFactory,
Cache cache,
SnapshotTriggerDefinition snapshotTriggerDefinition,
RepositoryProvider repositoryProvider)
Initializes a repository with a the given
aggregateFactory and a pessimistic locking strategy. |
EventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore)
Initializes a repository with the default locking strategy, using the given
aggregateFactory to
create new aggregate instances. |
EventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore,
LockFactory lockFactory,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition,
SnapshotTriggerDefinition snapshotTriggerDefinition,
RepositoryProvider repositoryProvider)
Initialize a repository with the given locking strategy and parameter resolver factory.
|
EventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore,
LockFactory lockFactory,
ParameterResolverFactory parameterResolverFactory,
SnapshotTriggerDefinition snapshotTriggerDefinition)
Initialize a repository with the given locking strategy and parameter resolver factory.
|
EventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore,
LockFactory lockFactory,
SnapshotTriggerDefinition snapshotTriggerDefinition)
Initialize a repository with the given locking strategy.
|
EventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore,
LockFactory lockFactory,
SnapshotTriggerDefinition snapshotTriggerDefinition,
RepositoryProvider repositoryProvider)
Initialize a repository with the given locking strategy.
|
EventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition,
SnapshotTriggerDefinition snapshotTriggerDefinition,
RepositoryProvider repositoryProvider)
Initializes a repository with the default locking strategy, using the given
aggregateFactory to
create new aggregate instances. |
EventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore,
ParameterResolverFactory parameterResolverFactory,
SnapshotTriggerDefinition snapshotTriggerDefinition)
Initializes a repository with the default locking strategy, using the given
aggregateFactory to
create new aggregate instances. |
EventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore,
RepositoryProvider repositoryProvider)
Initializes a repository with the default locking strategy, using the given
aggregateFactory to
create new aggregate instances. |
EventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore,
SnapshotTriggerDefinition snapshotTriggerDefinition)
Initializes a repository with the default locking strategy, using the given
aggregateFactory to
create new aggregate instances and triggering snapshots using the given snapshotTriggerDefinition |
EventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore,
SnapshotTriggerDefinition snapshotTriggerDefinition,
RepositoryProvider repositoryProvider)
Initializes a repository with the default locking strategy, using the given
aggregateFactory to
create new aggregate instances and triggering snapshots using the given snapshotTriggerDefinition |
EventSourcingRepository(AggregateModel<T> aggregateModel,
AggregateFactory<T> aggregateFactory,
EventStore eventStore)
Initializes a repository with the default locking strategy, using the given
aggregateFactory to
create new aggregate instances. |
EventSourcingRepository(AggregateModel<T> aggregateModel,
AggregateFactory<T> aggregateFactory,
EventStore eventStore,
RepositoryProvider repositoryProvider)
Initializes a repository with the default locking strategy, using the given
aggregateFactory to
create new aggregate instances. |
EventSourcingRepository(AggregateModel<T> aggregateModel,
AggregateFactory<T> aggregateFactory,
EventStore eventStore,
SnapshotTriggerDefinition snapshotTriggerDefinition)
Initializes a repository with the default locking strategy, using the given
aggregateFactory to
create new aggregate instances and triggering snapshots using the given snapshotTriggerDefinition |
EventSourcingRepository(AggregateModel<T> aggregateModel,
AggregateFactory<T> aggregateFactory,
EventStore eventStore,
SnapshotTriggerDefinition snapshotTriggerDefinition,
RepositoryProvider repositoryProvider)
Initializes a repository with the default locking strategy, using the given
aggregateFactory to
create new aggregate instances and triggering snapshots using the given snapshotTriggerDefinition |
EventSourcingRepository(Class<T> aggregateType,
EventStore eventStore)
Initializes a repository with the default locking strategy, using a GenericAggregateFactory to create new
aggregate instances of given
aggregateType . |
EventSourcingRepository(Class<T> aggregateType,
EventStore eventStore,
RepositoryProvider repositoryProvider)
Initializes a repository with the default locking strategy, using a GenericAggregateFactory to create new
aggregate instances of given
aggregateType . |
EventSourcingRepository(Class<T> aggregateType,
EventStore eventStore,
SnapshotTriggerDefinition snapshotTriggerDefinition)
Initializes a repository with the default locking strategy, using a GenericAggregateFactory to create new
aggregate instances of given
aggregateType . |
EventSourcingRepository(Class<T> aggregateType,
EventStore eventStore,
SnapshotTriggerDefinition snapshotTriggerDefinition,
RepositoryProvider repositoryProvider)
Initializes a repository with the default locking strategy, using a GenericAggregateFactory to create new
aggregate instances of given
aggregateType . |
Modifier and Type | Class and Description |
---|---|
class |
AbstractEventStore
Abstract implementation of an
EventStore that uses a EventStorageEngine to store and load events. |
class |
EmbeddedEventStore
Implementation of an
EventStore that stores and fetches events using an EventStorageEngine . |
Modifier and Type | Method and Description |
---|---|
void |
SpringAggregateSnapshotterFactoryBean.setEventStore(EventStore eventStore)
Sets the Event Store instance to write the snapshots to
|
Constructor and Description |
---|
SpringAggregateSnapshotter(EventStore eventStore,
ParameterResolverFactory parameterResolverFactory,
Executor executor,
TransactionManager txManager)
Initializes a snapshotter.
|
SpringAggregateSnapshotter(EventStore eventStore,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition,
Executor executor,
TransactionManager txManager,
RepositoryProvider repositoryProvider)
Initializes a snapshotter using the ParameterResolverFactory instances available on the classpath.
|
Modifier and Type | Method and Description |
---|---|
EventStore |
FixtureConfiguration.getEventStore()
Returns the event store used by this fixture.
|
EventStore |
AggregateTestFixture.getEventStore() |
Copyright © 2010–2018. All rights reserved.