Uses of Interface
org.axonframework.eventsourcing.DomainEventMessage

Packages that use DomainEventMessage

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

Uses of DomainEventMessage in org.axonframework.commandhandling.conflictresolution

Methods in org.axonframework.commandhandling.conflictresolution that return types with arguments of type DomainEventMessage

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<?>>	DefaultConflictDescription.unexpectedEvents()
List<DomainEventMessage<?>>	ConflictDescription.unexpectedEvents() The list of events that have been registered with this aggregate since the expected version.

Method parameters in org.axonframework.commandhandling.conflictresolution with type arguments of type DomainEventMessage

Modifier and Type	Method and Description
void	NoConflictResolver.detectConflicts(Predicate<List<DomainEventMessage<?>>> predicate)
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> void	NoConflictResolver.detectConflicts(Predicate<List<DomainEventMessage<?>>> predicate, ConflictExceptionSupplier<T> exceptionSupplier)
default <T extends Exception> void	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> void	NoConflictResolver.detectConflicts(Predicate<List<DomainEventMessage<?>>> predicate, ContextAwareConflictExceptionSupplier<T> exceptionSupplier)
<T extends Exception> void	DefaultConflictResolver.detectConflicts(Predicate<List<DomainEventMessage<?>>> predicate, ContextAwareConflictExceptionSupplier<T> exceptionSupplier)
<T extends Exception> void	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.

Constructor parameters in org.axonframework.commandhandling.conflictresolution with type arguments of type DomainEventMessage

Constructor and Description
DefaultConflictDescription(String aggregateIdentifier, long expectedVersion, long actualVersion, List<DomainEventMessage<?>> unexpectedEvents) Initialize the instance using given values.

Uses of DomainEventMessage in org.axonframework.eventsourcing

Classes in org.axonframework.eventsourcing that implement DomainEventMessage

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.

Methods in org.axonframework.eventsourcing that return DomainEventMessage

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 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.

Methods in org.axonframework.eventsourcing that return types with arguments of type DomainEventMessage

Modifier and Type	Method and Description
Optional<DomainEventMessage<?>>	FilteringEventStorageEngine.readSnapshot(String aggregateIdentifier)

Methods in org.axonframework.eventsourcing with parameters of type DomainEventMessage

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)

Constructors in org.axonframework.eventsourcing with parameters of type DomainEventMessage

Constructor and Description
GenericTrackedDomainEventMessage(TrackingToken trackingToken, DomainEventMessage<T> delegate) Initialize a DomainEventMessage originating from an aggregate.

Uses of DomainEventMessage in org.axonframework.eventsourcing.eventstore

Methods in org.axonframework.eventsourcing.eventstore that return DomainEventMessage

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<?>	FilteringDomainEventStream.next()
DomainEventMessage<?>	DomainEventStream.next() Returns the next events in the stream, if available.
DomainEventMessage<?>	ConcatenatingDomainEventStream.next()
DomainEventMessage<?>	IteratorBackedDomainEventStream.peek()
DomainEventMessage<?>	FilteringDomainEventStream.peek()
DomainEventMessage<?>	DomainEventStream.peek() Returns the next events in the stream, if available, without moving the pointer forward.
DomainEventMessage<?>	ConcatenatingDomainEventStream.peek()

Methods in org.axonframework.eventsourcing.eventstore that return types with arguments of type DomainEventMessage

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.
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<?>>	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.

Methods in org.axonframework.eventsourcing.eventstore with parameters of type DomainEventMessage

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.

Method parameters in org.axonframework.eventsourcing.eventstore with type arguments of type DomainEventMessage

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.

Constructors in org.axonframework.eventsourcing.eventstore with parameters of type DomainEventMessage

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 parameters in org.axonframework.eventsourcing.eventstore with type arguments of type DomainEventMessage

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

Uses of DomainEventMessage in org.axonframework.eventsourcing.eventstore.inmemory

Methods in org.axonframework.eventsourcing.eventstore.inmemory that return types with arguments of type DomainEventMessage

Modifier and Type	Method and Description
Optional<DomainEventMessage<?>>	InMemoryEventStorageEngine.readSnapshot(String aggregateIdentifier)

Methods in org.axonframework.eventsourcing.eventstore.inmemory with parameters of type DomainEventMessage

Modifier and Type	Method and Description
void	InMemoryEventStorageEngine.storeSnapshot(DomainEventMessage<?> snapshot)

Uses of DomainEventMessage in org.axonframework.eventsourcing.eventstore.jdbc

Methods in org.axonframework.eventsourcing.eventstore.jdbc with parameters of type DomainEventMessage

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)

Uses of DomainEventMessage in org.axonframework.eventsourcing.eventstore.jpa

Methods in org.axonframework.eventsourcing.eventstore.jpa with parameters of type DomainEventMessage

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)

Constructors in org.axonframework.eventsourcing.eventstore.jpa with parameters of type DomainEventMessage

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.

Uses of DomainEventMessage in org.axonframework.mongo.eventsourcing.eventstore

Methods in org.axonframework.mongo.eventsourcing.eventstore with parameters of type DomainEventMessage

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)

Uses of DomainEventMessage in org.axonframework.mongo.eventsourcing.eventstore.documentpercommit

Methods in org.axonframework.mongo.eventsourcing.eventstore.documentpercommit with parameters of type DomainEventMessage

Modifier and Type	Method and Description
protected org.bson.Document	DocumentPerCommitStorageStrategy.createSnapshotDocument(DomainEventMessage<?> snapshot, Serializer serializer)

Constructor parameters in org.axonframework.mongo.eventsourcing.eventstore.documentpercommit with type arguments of type DomainEventMessage

Constructor and Description
CommitEntry(List<? extends DomainEventMessage<?>> events, Serializer serializer) Constructor used to create a new event entry to store in Mongo.

Uses of DomainEventMessage in org.axonframework.mongo.eventsourcing.eventstore.documentperevent

Methods in org.axonframework.mongo.eventsourcing.eventstore.documentperevent with parameters of type DomainEventMessage

Modifier and Type	Method and Description
protected org.bson.Document	DocumentPerEventStorageStrategy.createSnapshotDocument(DomainEventMessage<?> snapshot, Serializer serializer)

Constructors in org.axonframework.mongo.eventsourcing.eventstore.documentperevent with parameters of type DomainEventMessage

Constructor and Description
EventEntry(DomainEventMessage<?> event, Serializer serializer) Constructor used to create a new event entry to store in Mongo.

Uses of DomainEventMessage in org.axonframework.spring.eventsourcing

Methods in org.axonframework.spring.eventsourcing with parameters of type DomainEventMessage

Modifier and Type	Method and Description
T	SpringPrototypeAggregateFactory.createAggregateRoot(String aggregateIdentifier, DomainEventMessage<?> firstEvent)