Uses of Interface
org.axonframework.eventhandling.DomainEventMessage

Packages that use DomainEventMessage

Package	Description
org.axonframework.axonserver.connector.event.axon
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.eventsourcing.eventstore.legacyjpa
org.axonframework.spring.eventsourcing

Uses of DomainEventMessage in org.axonframework.axonserver.connector.event.axon

Methods in org.axonframework.axonserver.connector.event.axon that return types with arguments of type DomainEventMessage

Modifier and Type	Method and Description
protected Optional<DomainEventMessage<?>>	AxonServerEventStore.handleSnapshotReadingError(String aggregateIdentifier, Throwable e)

Uses of DomainEventMessage in org.axonframework.config

Method parameters in org.axonframework.config with type arguments of type DomainEventMessage

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.

Uses of DomainEventMessage in org.axonframework.eventhandling

Classes in org.axonframework.eventhandling 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.eventhandling 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.
static <T> DomainEventMessage<T>	EventUtils.asDomainEventMessage(EventMessage<T> eventMessage) Deprecated. since this method is not used for external use. This method is intended to deduce whether a given EventMessage is a DomainEventMessage and if not, push it into being one by adjusting the fields. However, this is only intended to simplify the storage of events. This does not make a regular EventMessage a DomainEventMessage by any means. The only way to have a true DomainEventMessage is by publishing events from within an Aggregate, by using the AggregateLifecycle operations.
DomainEventMessage<T>	DomainEventMessage.withMetaData(Map<String,?> metaData) Returns a copy of this DomainEventMessage with the given metaData.

Constructors in org.axonframework.eventhandling 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.
GenericTrackedDomainEventMessage(TrackingToken trackingToken, DomainEventMessage<T> delegate) Initialize a DomainEventMessage originating from an aggregate.

Uses of DomainEventMessage in org.axonframework.eventsourcing

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

Modifier and Type	Field and Description
protected Predicate<? super DomainEventMessage<?>>	EventSourcingRepository.Builder.eventStreamFilter

Methods in org.axonframework.eventsourcing that return DomainEventMessage

Modifier and Type	Method and Description
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.

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

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)

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)

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

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.

Uses of DomainEventMessage in org.axonframework.eventsourcing.conflictresolution

Methods in org.axonframework.eventsourcing.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.eventsourcing.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.eventsourcing.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.eventstore

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

Modifier and Type	Method and Description
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.
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
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 be used at AbstractEventStorageEngine.storeSnapshot(DomainEventMessage).
protected void	JdbcEventStorageEngine.storeSnapshot(DomainEventMessage<?> snapshot, Serializer serializer)

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

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

Modifier and Type	Method and Description
protected static <T> DomainEventMessage<T>	JdbcEventStorageEngineStatements.asDomainEventMessage(EventMessage<T> event) Converts an EventMessage to a DomainEventMessage.

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

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)

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

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

Modifier and Type	Method and Description
protected static <T> DomainEventMessage<T>	JpaEventStorageEngine.asDomainEventMessage(EventMessage<T> event) Converts an EventMessage to a DomainEventMessage.

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.eventsourcing.eventstore.legacyjpa

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

Modifier and Type	Method and Description
protected static <T> DomainEventMessage<T>	JpaEventStorageEngine.asDomainEventMessage(EventMessage<T> event) Deprecated. Converts an EventMessage to a DomainEventMessage.

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

Modifier and Type	Method and Description
protected Object	JpaEventStorageEngine.createSnapshotEntity(DomainEventMessage<?> snapshot, Serializer serializer) Deprecated. Returns a Jpa snapshot entity for given snapshot of an aggregate.
protected void	JpaEventStorageEngine.storeSnapshot(DomainEventMessage<?> snapshot, Serializer serializer) Deprecated.

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)