Package | Description |
---|---|
org.axonframework.commandhandling.conflictresolution | |
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.eventsourcing.eventstore.inmemory | |
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.mongo.eventsourcing.eventstore.documentpercommit | |
org.axonframework.mongo.eventsourcing.eventstore.documentperevent | |
org.axonframework.spring.eventsourcing | |
org.axonframework.test.aggregate |
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 . |
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.
|
<T extends Exception> |
NoConflictResolver.detectConflicts(Predicate<List<DomainEventMessage<?>>> predicate,
ConflictExceptionSupplier<T> exceptionSupplier) |
<T extends Exception> |
DefaultConflictResolver.detectConflicts(Predicate<List<DomainEventMessage<?>>> predicate,
ConflictExceptionSupplier<T> exceptionSupplier) |
<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.
|
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 . |
protected <P> DomainEventMessage<P> |
EventSourcedAggregate.createMessage(P payload,
MetaData metaData) |
protected DomainEventMessage |
AggregateSnapshotter.createSnapshot(Class<?> aggregateType,
String aggregateIdentifier,
DomainEventStream eventStream) |
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 . |
DomainEventMessage<T> |
DomainEventMessage.withMetaData(Map<String,?> metaData)
Returns a copy of this DomainEventMessage with the given
metaData . |
Modifier and Type | Method and Description |
---|---|
Optional<DomainEventMessage<?>> |
FilteringEventStorageEngine.readSnapshot(String aggregateIdentifier) |
Modifier and Type | Method and Description |
---|---|
T |
AggregateFactory.createAggregateRoot(String aggregateIdentifier,
DomainEventMessage<?> firstEvent)
Instantiate the aggregate root using the given aggregate identifier and first event.
|
T |
AbstractAggregateFactory.createAggregateRoot(String aggregateIdentifier,
DomainEventMessage<?> firstEvent) |
protected T |
GenericAggregateFactory.doCreateAggregate(String aggregateIdentifier,
DomainEventMessage firstEvent)
Create an uninitialized Aggregate instance with the given
aggregateIdentifier . |
protected abstract T |
AbstractAggregateFactory.doCreateAggregate(String aggregateIdentifier,
DomainEventMessage firstEvent)
Create an uninitialized Aggregate instance with the given
aggregateIdentifier . |
void |
FilteringEventStorageEngine.storeSnapshot(DomainEventMessage<?> snapshot) |
Constructor and Description |
---|
GenericTrackedDomainEventMessage(TrackingToken trackingToken,
DomainEventMessage<T> delegate)
Initialize a DomainEventMessage originating from an aggregate.
|
Modifier and Type | Method and Description |
---|---|
static <T> DomainEventMessage<T> |
EventUtils.asDomainEventMessage(EventMessage<T> eventMessage)
Convert a plain
EventMessage to a DomainEventMessage . |
DomainEventMessage<?> |
IteratorBackedDomainEventStream.next() |
DomainEventMessage<?> |
DomainEventStream.next()
Returns the next events in the stream, if available.
|
DomainEventMessage<?> |
ConcatenatingDomainEventStream.next() |
DomainEventMessage<?> |
IteratorBackedDomainEventStream.peek() |
DomainEventMessage<?> |
DomainEventStream.peek()
Returns the next events in the stream, if available, without moving the pointer forward.
|
DomainEventMessage<?> |
ConcatenatingDomainEventStream.peek() |
Modifier and Type | Method and Description |
---|---|
default Stream<? extends DomainEventMessage<?>> |
DomainEventStream.asStream()
Returns this DomainEventStream as a
Stream of DomainEventMessages. |
static Stream<? extends DomainEventMessage<?>> |
EventUtils.asStream(DomainEventStream domainEventStream)
Convert the given
domainEventStream to a regular java Stream of domain event messages. |
Optional<DomainEventMessage<?>> |
SequenceEventStorageEngine.readSnapshot(String aggregateIdentifier) |
Optional<DomainEventMessage<?>> |
EventStorageEngine.readSnapshot(String aggregateIdentifier)
Try to load a snapshot event of the aggregate with given
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 |
SequenceEventStorageEngine.storeSnapshot(DomainEventMessage<?> snapshot) |
void |
EventStore.storeSnapshot(DomainEventMessage<?> snapshot)
Stores the given (temporary)
snapshot event. |
void |
EventStorageEngine.storeSnapshot(DomainEventMessage<?> snapshot)
Store an event that contains a snapshot of an aggregate.
|
void |
AbstractEventStore.storeSnapshot(DomainEventMessage<?> snapshot) |
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 |
---|---|
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 |
---|
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.
|
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 |
---|
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 append the given
snapshot to the event storage using given connection to
the database. |
protected void |
JdbcEventStorageEngine.storeSnapshot(DomainEventMessage<?> snapshot,
Serializer 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 |
---|---|
void |
StorageStrategy.appendSnapshot(com.mongodb.client.MongoCollection<org.bson.Document> snapshotCollection,
DomainEventMessage<?> snapshot,
Serializer serializer)
Append the given aggregate
snapshot to the snapshotCollection . |
void |
AbstractMongoEventStorageStrategy.appendSnapshot(com.mongodb.client.MongoCollection<org.bson.Document> snapshotCollection,
DomainEventMessage<?> snapshot,
Serializer serializer) |
protected abstract org.bson.Document |
AbstractMongoEventStorageStrategy.createSnapshotDocument(DomainEventMessage<?> snapshot,
Serializer serializer)
Returns a Mongo document for given snapshot event.
|
protected void |
MongoEventStorageEngine.storeSnapshot(DomainEventMessage<?> snapshot,
Serializer serializer) |
Modifier and Type | Method and Description |
---|---|
protected org.bson.Document |
DocumentPerCommitStorageStrategy.createSnapshotDocument(DomainEventMessage<?> snapshot,
Serializer serializer) |
Constructor and Description |
---|
CommitEntry(List<? extends DomainEventMessage<?>> events,
Serializer serializer)
Constructor used to create a new event entry to store in Mongo.
|
Modifier and Type | Method and Description |
---|---|
protected org.bson.Document |
DocumentPerEventStorageStrategy.createSnapshotDocument(DomainEventMessage<?> snapshot,
Serializer serializer) |
Constructor and Description |
---|
EventEntry(DomainEventMessage<?> event,
Serializer serializer)
Constructor used to create a new event entry to store in Mongo.
|
Modifier and Type | Method and Description |
---|---|
T |
SpringPrototypeAggregateFactory.createAggregateRoot(String aggregateIdentifier,
DomainEventMessage<?> firstEvent) |
Modifier and Type | Method and Description |
---|---|
void |
Reporter.reportDifferenceInStoredVsPublished(Collection<DomainEventMessage<?>> storedEvents,
Collection<EventMessage<?>> publishedEvents,
Throwable probableCause)
Report a failed assertion due to a difference in the stored versus the published events.
|
Copyright © 2010–2017. All rights reserved.