Package | Description |
---|---|
org.axonframework.config | |
org.axonframework.eventhandling |
Classes related to event handling and dispatching, such as
Event Listeners and the Event Bus . |
org.axonframework.eventsourcing |
Classes related to event sourcing.
|
org.axonframework.eventsourcing.conflictresolution | |
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.inmemory | |
org.axonframework.eventsourcing.eventstore.jdbc |
JDBC Implementation of the EventStore.
|
org.axonframework.eventsourcing.eventstore.jdbc.statements | |
org.axonframework.eventsourcing.eventstore.jpa |
JPA Implementation of the EventStore.
|
org.axonframework.spring.eventsourcing |
Modifier and Type | Method and Description |
---|---|
AggregateConfigurer<A> |
AggregateConfigurer.configureEventStreamFilter(Function<Configuration,Predicate<? super DomainEventMessage<?>>> filterBuilder)
Configures an event stream filter for the EventSourcingRepository for the Aggregate type under configuration.
|
Modifier and Type | Class and Description |
---|---|
class |
GenericDomainEventMessage<T>
Generic implementation of a
DomainEventMessage . |
class |
GenericTrackedDomainEventMessage<T>
Generic implementation of a
DomainEventMessage that is also a TrackedEventMessage . |
Modifier and Type | Method and Description |
---|---|
DomainEventMessage<T> |
DomainEventMessage.andMetaData(Map<String,?> metaData)
Returns a copy of this DomainEventMessage with its MetaData merged with the given
metaData . |
static <T> DomainEventMessage<T> |
EventUtils.asDomainEventMessage(EventMessage<T> eventMessage)
Convert a plain
EventMessage to a DomainEventMessage . |
DomainEventMessage<T> |
DomainEventMessage.withMetaData(Map<String,?> metaData)
Returns a copy of this DomainEventMessage with the given
metaData . |
Constructor and Description |
---|
AbstractDomainEventEntry(DomainEventMessage<?> eventMessage,
Serializer serializer,
Class<T> contentType)
Construct a new event entry from a published domain event message to enable storing the event or sending it to a
remote location.
|
AbstractSequencedDomainEventEntry(DomainEventMessage<?> eventMessage,
Serializer serializer,
Class<T> contentType)
Construct a new default domain event entry from a published domain event message to enable storing the event or
sending it to a remote location.
|
GenericTrackedDomainEventMessage(TrackingToken trackingToken,
DomainEventMessage<T> delegate)
Initialize a DomainEventMessage originating from an aggregate.
|
Modifier and Type | Field and Description |
---|---|
protected Predicate<? super DomainEventMessage<?>> |
EventSourcingRepository.Builder.eventStreamFilter |
Modifier and Type | Method and Description |
---|---|
protected abstract DomainEventMessage |
AbstractSnapshotter.createSnapshot(Class<?> aggregateType,
String aggregateIdentifier,
DomainEventStream eventStream)
Creates a snapshot event for an aggregate of which passed events are available in the given
eventStream . |
protected DomainEventMessage |
AggregateSnapshotter.createSnapshot(Class<?> aggregateType,
String aggregateIdentifier,
DomainEventStream eventStream) |
Modifier and Type | Method and Description |
---|---|
static Stream<? extends DomainEventMessage<?>> |
EventStreamUtils.asStream(DomainEventStream domainEventStream)
Convert the given
domainEventStream to a regular java Stream of domain event messages. |
Optional<DomainEventMessage<?>> |
FilteringEventStorageEngine.readSnapshot(String aggregateIdentifier) |
Modifier and Type | Method and Description |
---|---|
T |
AbstractAggregateFactory.createAggregateRoot(String aggregateIdentifier,
DomainEventMessage<?> firstEvent) |
T |
AggregateFactory.createAggregateRoot(String aggregateIdentifier,
DomainEventMessage<?> firstEvent)
Instantiate the aggregate root using the given aggregate identifier and first event.
|
protected abstract T |
AbstractAggregateFactory.doCreateAggregate(String aggregateIdentifier,
DomainEventMessage firstEvent)
Create an uninitialized Aggregate instance with the given
aggregateIdentifier . |
protected T |
GenericAggregateFactory.doCreateAggregate(String aggregateIdentifier,
DomainEventMessage firstEvent)
Create an uninitialized Aggregate instance with the given
aggregateIdentifier . |
void |
FilteringEventStorageEngine.storeSnapshot(DomainEventMessage<?> snapshot) |
Modifier and Type | Method and Description |
---|---|
EventSourcingRepository.Builder<T> |
EventSourcingRepository.Builder.eventStreamFilter(Predicate<? super DomainEventMessage<?>> filter)
Sets the
Predicate used to filter events when reading from the EventStore. |
Modifier and Type | Method and Description |
---|---|
static <T> Predicate<List<DomainEventMessage<?>>> |
Conflicts.payloadMatching(Class<T> payloadType,
Predicate<? super T> payloadFilter)
Returns a
Predicate for a ConflictResolver that responds affirmative if the payload of any event
in a list of unseen events is of given payloadType and matches the given messageFilter . |
static Predicate<List<DomainEventMessage<?>>> |
Conflicts.payloadMatching(Predicate<Object> payloadFilter)
Returns a
Predicate for a ConflictResolver that responds affirmative if the payload of any event
in a list of unseen events matches the given messageFilter . |
static <T> Predicate<List<DomainEventMessage<?>>> |
Conflicts.payloadTypeOf(Class<T> payloadType)
Returns a
Predicate for a ConflictResolver that responds affirmative if the payload type of any
event in a list of unseen events is assignable to given payloadType . |
List<DomainEventMessage<?>> |
ConflictDescription.unexpectedEvents()
The list of events that have been registered with this aggregate since the expected version.
|
List<DomainEventMessage<?>> |
DefaultConflictDescription.unexpectedEvents() |
Modifier and Type | Method and Description |
---|---|
default void |
ConflictResolver.detectConflicts(Predicate<List<DomainEventMessage<?>>> predicate)
Resolve conflicts between changes to be applied to the aggregate and unseen changes made to the aggregate.
|
void |
NoConflictResolver.detectConflicts(Predicate<List<DomainEventMessage<?>>> predicate) |
default <T extends Exception> |
ConflictResolver.detectConflicts(Predicate<List<DomainEventMessage<?>>> predicate,
ConflictExceptionSupplier<T> exceptionSupplier)
Resolve conflicts between unseen changes made to the aggregate and new changes that are about to be made.
|
<T extends Exception> |
NoConflictResolver.detectConflicts(Predicate<List<DomainEventMessage<?>>> predicate,
ConflictExceptionSupplier<T> exceptionSupplier) |
<T extends Exception> |
ConflictResolver.detectConflicts(Predicate<List<DomainEventMessage<?>>> predicate,
ContextAwareConflictExceptionSupplier<T> exceptionSupplier)
Resolve conflicts between unseen changes made to the aggregate and new changes that are about to be made.
|
<T extends Exception> |
DefaultConflictResolver.detectConflicts(Predicate<List<DomainEventMessage<?>>> predicate,
ContextAwareConflictExceptionSupplier<T> exceptionSupplier) |
<T extends Exception> |
NoConflictResolver.detectConflicts(Predicate<List<DomainEventMessage<?>>> predicate,
ContextAwareConflictExceptionSupplier<T> exceptionSupplier) |
Constructor and Description |
---|
DefaultConflictDescription(String aggregateIdentifier,
long expectedVersion,
long actualVersion,
List<DomainEventMessage<?>> unexpectedEvents)
Initialize the instance using given values.
|
Modifier and Type | Method and Description |
---|---|
DomainEventMessage<?> |
ConcatenatingDomainEventStream.next() |
DomainEventMessage<?> |
IteratorBackedDomainEventStream.next() |
DomainEventMessage<?> |
FilteringDomainEventStream.next() |
DomainEventMessage<?> |
DomainEventStream.next()
Returns the next events in the stream, if available.
|
DomainEventMessage<?> |
ConcatenatingDomainEventStream.peek() |
DomainEventMessage<?> |
IteratorBackedDomainEventStream.peek() |
DomainEventMessage<?> |
FilteringDomainEventStream.peek() |
DomainEventMessage<?> |
DomainEventStream.peek()
Returns the next events in the stream, if available, without moving the pointer forward.
|
Modifier and Type | Method and Description |
---|---|
default Stream<? extends DomainEventMessage<?>> |
DomainEventStream.asStream()
Returns this DomainEventStream as a
Stream of DomainEventMessages. |
protected Optional<DomainEventMessage<?>> |
AbstractEventStore.handleSnapshotReadingError(String aggregateIdentifier,
Throwable e)
Invoked when an error (
Exception or LinkageError ) occurs while attempting to read a snapshot
event. |
Optional<DomainEventMessage<?>> |
EventStorageEngine.readSnapshot(String aggregateIdentifier)
Try to load a snapshot event of the aggregate with given
aggregateIdentifier . |
Optional<DomainEventMessage<?>> |
SequenceEventStorageEngine.readSnapshot(String aggregateIdentifier) |
Optional<DomainEventMessage<?>> |
AbstractEventStorageEngine.readSnapshot(String aggregateIdentifier) |
protected Stream<? extends DomainEventMessage<?>> |
AbstractEventStore.stagedDomainEventMessages(String aggregateIdentifier)
Returns a Stream of all DomainEventMessages that have been staged for publication by an Aggregate with given
aggregateIdentifier . |
Modifier and Type | Method and Description |
---|---|
static DomainEventStream |
DomainEventStream.of(DomainEventMessage<?>... events)
Create a new DomainEventStream from the given
events . |
static DomainEventStream |
DomainEventStream.of(DomainEventMessage<?> event)
Create a new DomainEventStream containing only the given
event . |
void |
EventStorageEngine.storeSnapshot(DomainEventMessage<?> snapshot)
Store an event that contains a snapshot of an aggregate.
|
void |
AbstractEventStore.storeSnapshot(DomainEventMessage<?> snapshot) |
void |
SequenceEventStorageEngine.storeSnapshot(DomainEventMessage<?> snapshot) |
void |
EventStore.storeSnapshot(DomainEventMessage<?> snapshot)
Stores the given (temporary)
snapshot event. |
void |
AbstractEventStorageEngine.storeSnapshot(DomainEventMessage<?> snapshot) |
protected abstract void |
AbstractEventStorageEngine.storeSnapshot(DomainEventMessage<?> snapshot,
Serializer serializer)
Store the given
snapshot of an Aggregate. |
Modifier and Type | Method and Description |
---|---|
default DomainEventStream |
DomainEventStream.filter(Predicate<? super DomainEventMessage<?>> filter)
Returns a stream that provides the items of this stream that match the given
filter . |
static DomainEventStream |
DomainEventStream.of(List<? extends DomainEventMessage<?>> list)
Create a new DomainEventStream with events obtained from the given
list . |
static DomainEventStream |
DomainEventStream.of(Stream<? extends DomainEventMessage<?>> stream)
Create a new DomainEventStream with events obtained from the given
stream . |
static DomainEventStream |
DomainEventStream.of(Stream<? extends DomainEventMessage<?>> stream,
Supplier<Long> sequenceNumberSupplier)
Create a new DomainEventStream with events obtained from the given
stream . |
Constructor and Description |
---|
AbstractSnapshotEventEntry(DomainEventMessage<?> eventMessage,
Serializer serializer,
Class<T> contentType)
Construct a new event entry from a published domain event message to enable storing the event or sending it to a
remote location.
|
Constructor and Description |
---|
FilteringDomainEventStream(DomainEventStream delegate,
Predicate<? super DomainEventMessage<?>> filter)
Initialize the stream, filter the given
stream with the given
filter . |
IteratorBackedDomainEventStream(Iterator<? extends DomainEventMessage<?>> iterator)
Initialize the stream which provides access to message from the given
iterator |
Modifier and Type | Method and Description |
---|---|
Optional<DomainEventMessage<?>> |
InMemoryEventStorageEngine.readSnapshot(String aggregateIdentifier) |
Modifier and Type | Method and Description |
---|---|
void |
InMemoryEventStorageEngine.storeSnapshot(DomainEventMessage<?> snapshot) |
Modifier and Type | Method and Description |
---|---|
protected PreparedStatement |
JdbcEventStorageEngine.appendSnapshot(Connection connection,
DomainEventMessage<?> snapshot,
Serializer serializer)
Creates a statement to be used at
AbstractEventStorageEngine.storeSnapshot(DomainEventMessage) . |
protected void |
JdbcEventStorageEngine.storeSnapshot(DomainEventMessage<?> snapshot,
Serializer serializer) |
Modifier and Type | Method and Description |
---|---|
static PreparedStatement |
JdbcEventStorageEngineStatements.appendSnapshot(Connection connection,
EventSchema schema,
Class<?> dataType,
DomainEventMessage<?> snapshot,
Serializer serializer,
TimestampWriter timestampWriter)
Set the PreparedStatement to be used on
JdbcEventStorageEngine.storeSnapshot(DomainEventMessage,
Serializer) . |
PreparedStatement |
AppendSnapshotStatementBuilder.build(Connection connection,
EventSchema schema,
Class<?> dataType,
DomainEventMessage<?> snapshot,
Serializer serializer,
TimestampWriter timestampWriter)
Creates a statement to be used at
JdbcEventStorageEngine.storeSnapshot(DomainEventMessage, Serializer) |
Modifier and Type | Method and Description |
---|---|
protected Object |
JpaEventStorageEngine.createSnapshotEntity(DomainEventMessage<?> snapshot,
Serializer serializer)
Returns a Jpa snapshot entity for given
snapshot of an aggregate. |
protected void |
JpaEventStorageEngine.storeSnapshot(DomainEventMessage<?> snapshot,
Serializer serializer) |
Constructor and Description |
---|
DomainEventEntry(DomainEventMessage<?> eventMessage,
Serializer serializer)
Construct a new default domain event entry from a published domain event message to enable storing the event or
sending it to a remote location.
|
SnapshotEventEntry(DomainEventMessage<?> eventMessage,
Serializer serializer)
Construct a new default snapshot event entry from an aggregate.
|
Modifier and Type | Method and Description |
---|---|
T |
SpringPrototypeAggregateFactory.createAggregateRoot(String aggregateIdentifier,
DomainEventMessage<?> firstEvent) |
Copyright © 2010–2020. All rights reserved.