Uses of Interface
org.axonframework.domain.DomainEventMessage

Packages that use DomainEventMessage

org.axonframework.commandhandling.disruptor
org.axonframework.domain	The domain components of the Axon Framework, mainly the Aggregates and Events.
org.axonframework.eventhandling.replay
org.axonframework.eventsourcing	Classes related to event sourcing.
org.axonframework.eventsourcing.annotation
org.axonframework.eventsourcing.conflictresolvers
org.axonframework.eventstore	Definitions and implementations of the Event store, the mechanism that can load event streams and append events to them.
org.axonframework.eventstore.fs	Package containing classes necessary to implement a FileSystem based implementation of the EventStore
org.axonframework.eventstore.jdbc	JDBC Implementation of the EventStore.
org.axonframework.eventstore.jpa	JPA Implementation of the EventStore.
org.axonframework.eventstore.mongo
org.axonframework.eventstore.supporting
org.axonframework.gae.eventstore
org.axonframework.mongo3.eventstore
org.axonframework.quickstart.handler
org.axonframework.serializer
org.axonframework.test	Classes in support of testing Axon based applications.
org.axonframework.upcasting

Uses of DomainEventMessage in org.axonframework.commandhandling.disruptor

Methods in org.axonframework.commandhandling.disruptor that return DomainEventMessage

<T> DomainEventMessage<T>

DisruptorUnitOfWork.onRegisteredEvent(DomainEventMessage<T> event)

Methods in org.axonframework.commandhandling.disruptor with parameters of type DomainEventMessage

<T> DomainEventMessage<T>

DisruptorUnitOfWork.onRegisteredEvent(DomainEventMessage<T> event)

Uses of DomainEventMessage in org.axonframework.domain

Classes in org.axonframework.domain that implement DomainEventMessage

class

GenericDomainEventMessage<T> Generic implementation of the DomainEventMessage interface.

Methods in org.axonframework.domain that return DomainEventMessage

<T> DomainEventMessage<T>	EventContainer.addEvent(DomainEventMessage<T> domainEventMessage) Add an event to this container.
<T> DomainEventMessage<T>	EventContainer.addEvent(MetaData metaData, T payload) Add an event to this container.
DomainEventMessage<T>	DomainEventMessage.andMetaData(Map<String,?> metaData) Returns a copy of this DomainEventMessage with its MetaData merged with the given metaData.
DomainEventMessage	SimpleDomainEventStream.next() Returns the next events in the stream, if available.
DomainEventMessage	DomainEventStream.next() Returns the next events in the stream, if available.
<T> DomainEventMessage<T>	EventRegistrationCallback.onRegisteredEvent(DomainEventMessage<T> event) Invoked when an Aggregate registers an Event for publication.
DomainEventMessage	SimpleDomainEventStream.peek() Returns the next events in the stream, if available, without moving the pointer forward.
DomainEventMessage	DomainEventStream.peek() Returns the next events in the stream, if available, without moving the pointer forward.
protected <T> DomainEventMessage<T>	AbstractAggregateRoot.registerEvent(MetaData metaData, T payload) Registers an event to be published when the aggregate is saved.
protected <T> DomainEventMessage<T>	AbstractAggregateRoot.registerEvent(T payload) Registers an event to be published when the aggregate is saved, containing the given payload and no (additional) meta-data.
protected <T> DomainEventMessage<T>	AbstractAggregateRoot.registerEventMessage(DomainEventMessage<T> message) Registers an event message to be published when the aggregate is saved.
DomainEventMessage<T>	DomainEventMessage.withMetaData(Map<String,?> metaData) Returns a copy of this DomainEventMessage with the given metaData.

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

List<DomainEventMessage>

EventContainer.getEventList() Returns an unmodifiable version of the backing list of events.

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

<T> DomainEventMessage<T>	EventContainer.addEvent(DomainEventMessage<T> domainEventMessage) Add an event to this container.
<T> DomainEventMessage<T>	EventRegistrationCallback.onRegisteredEvent(DomainEventMessage<T> event) Invoked when an Aggregate registers an Event for publication.
protected <T> DomainEventMessage<T>	AbstractAggregateRoot.registerEventMessage(DomainEventMessage<T> message) Registers an event message to be published when the aggregate is saved.

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

SimpleDomainEventStream(DomainEventMessage... events)
Initialize the event stream using the given DomainEventMessages and aggregate identifier.

Constructor parameters in org.axonframework.domain with type arguments of type DomainEventMessage

SimpleDomainEventStream(Collection<? extends DomainEventMessage> events)
Initialize the event stream using the given List of DomainEvent and aggregate identifier.

Uses of DomainEventMessage in org.axonframework.eventhandling.replay

Methods in org.axonframework.eventhandling.replay with parameters of type DomainEventMessage

List<EventMessage>	IncomingMessageHandler.releaseMessage(Cluster destination, DomainEventMessage message) Invoked when a message has been replayed from the event store.
List<EventMessage>	DiscardingIncomingMessageHandler.releaseMessage(Cluster destination, DomainEventMessage message)
List<EventMessage>	BackloggingIncomingMessageHandler.releaseMessage(Cluster destination, DomainEventMessage message)

Uses of DomainEventMessage in org.axonframework.eventsourcing

Methods in org.axonframework.eventsourcing that return DomainEventMessage

protected DomainEventMessage	AggregateSnapshotter.createSnapshot(String typeIdentifier, Object aggregateIdentifier, DomainEventStream eventStream)
protected abstract DomainEventMessage	AbstractSnapshotter.createSnapshot(String typeIdentifier, Object aggregateIdentifier, DomainEventStream eventStream) Creates a snapshot event for an aggregate of the given typeIdentifier of which passed events are available in the given eventStream.

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

T	AggregateFactory.createAggregate(Object aggregateIdentifier, DomainEventMessage<?> firstEvent) Instantiate the aggregate using the given aggregate identifier and first event.
T	AbstractAggregateFactory.createAggregate(Object aggregateIdentifier, DomainEventMessage<?> firstEvent)
T	SpringPrototypeAggregateFactory.doCreateAggregate(Object aggregateIdentifier, DomainEventMessage firstEvent)
protected T	GenericAggregateFactory.doCreateAggregate(Object aggregateIdentifier, DomainEventMessage firstEvent) Create an uninitialized Aggregate instance with the given aggregateIdentifier.
protected abstract T	AbstractAggregateFactory.doCreateAggregate(Object aggregateIdentifier, DomainEventMessage firstEvent) Create an uninitialized Aggregate instance with the given aggregateIdentifier.
protected abstract void	AbstractEventSourcedEntity.handle(DomainEventMessage event) Apply state changes based on the given event.
protected abstract void	AbstractEventSourcedAggregateRoot.handle(DomainEventMessage event) Apply state changes based on the given event.
void	EventSourcedEntity.handleRecursively(DomainEventMessage event) Report the given event for handling in the current instance (this), as well as all the entities referenced by this instance.
void	AbstractEventSourcedEntity.handleRecursively(DomainEventMessage event)

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

void	ConflictResolver.resolveConflicts(List<DomainEventMessage> appliedChanges, List<DomainEventMessage> committedChanges) Checks the given list of appliedChanges and committedChanges for any conflicting changes.
void	ConflictResolver.resolveConflicts(List<DomainEventMessage> appliedChanges, List<DomainEventMessage> committedChanges) Checks the given list of appliedChanges and committedChanges for any conflicting changes.

Uses of DomainEventMessage in org.axonframework.eventsourcing.annotation

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

protected void	AbstractAnnotatedEntity.handle(DomainEventMessage event) Calls the appropriate handler method with the provided event.
protected void	AbstractAnnotatedAggregateRoot.handle(DomainEventMessage event) Calls the appropriate handler method with the provided event.

Uses of DomainEventMessage in org.axonframework.eventsourcing.conflictresolvers

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

void	AcceptAllConflictResolver.resolveConflicts(List<DomainEventMessage> appliedChanges, List<DomainEventMessage> committedChanges) Checks the given list of appliedChanges and committedChanges for any conflicting changes.
void	AcceptAllConflictResolver.resolveConflicts(List<DomainEventMessage> appliedChanges, List<DomainEventMessage> committedChanges) Checks the given list of appliedChanges and committedChanges for any conflicting changes.

Uses of DomainEventMessage in org.axonframework.eventstore

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

void	SnapshotEventStore.appendSnapshotEvent(String type, DomainEventMessage snapshotEvent) Append the given snapshotEvent to the snapshot event log for the given type type.
void	EventVisitor.doWithEvent(DomainEventMessage domainEvent) Called for each event loaded by the event store.

Uses of DomainEventMessage in org.axonframework.eventstore.fs

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

DomainEventMessage	FileSystemBufferedReaderDomainEventStream.next()
DomainEventMessage	FileSystemBufferedReaderDomainEventStream.peek()
DomainEventMessage	FileSystemSnapshotEventReader.readSnapshotEvent(String type, Object identifier) Reads the latest snapshot of the given aggregate identifier.

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

void	FileSystemEventStore.appendSnapshotEvent(String type, DomainEventMessage snapshotEvent) Append the given snapshotEvent to the snapshot event log for the given type type.
void	FileSystemEventMessageWriter.writeEventMessage(DomainEventMessage eventMessage) Writes the given eventMessage to the underling output.
void	FileSystemSnapshotEventWriter.writeSnapshotEvent(DomainEventMessage snapshotEvent) Writes the given snapshotEvent to the FileSystemSnapshotEventWriter.snapshotEventFile.

Uses of DomainEventMessage in org.axonframework.eventstore.jdbc

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

void	JdbcEventStore.appendSnapshotEvent(String type, DomainEventMessage snapshotEvent) Append the given snapshotEvent to the snapshot event log for the given type type.
void	EventEntryStore.persistEvent(String aggregateType, DomainEventMessage event, SerializedObject<T> serializedPayload, SerializedObject<T> serializedMetaData) Stores the given event (serialized as serializedPayload and serializedMetaData in the Event Store.
void	DefaultEventEntryStore.persistEvent(String aggregateType, DomainEventMessage event, SerializedObject<T> serializedPayload, SerializedObject<T> serializedMetaData)
void	EventEntryStore.persistSnapshot(String aggregateType, DomainEventMessage snapshotEvent, SerializedObject<T> serializedPayload, SerializedObject<T> serializedMetaData) Persists the given event which has been serialized into serializedEvent.
void	DefaultEventEntryStore.persistSnapshot(String aggregateType, DomainEventMessage snapshotEvent, SerializedObject<T> serializedPayload, SerializedObject<T> serializedMetaData)
void	EventEntryStore.pruneSnapshots(String type, DomainEventMessage mostRecentSnapshotEvent, int maxSnapshotsArchived) Removes old snapshots from the storage for an aggregate of given type that generated the given mostRecentSnapshotEvent.
void	DefaultEventEntryStore.pruneSnapshots(String type, DomainEventMessage mostRecentSnapshotEvent, int maxSnapshotsArchived)

Uses of DomainEventMessage in org.axonframework.eventstore.jpa

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

void	JpaEventStore.appendSnapshotEvent(String type, DomainEventMessage snapshotEvent) Append the given snapshotEvent to the snapshot event log for the given type type.
Object	DefaultEventEntryFactory.createDomainEventEntry(String aggregateType, DomainEventMessage event, SerializedObject<byte[]> serializedPayload, SerializedObject<byte[]> serializedMetaData)
Object	EventEntryFactory.createDomainEventEntry(String aggregateType, DomainEventMessage event, SerializedObject<T> serializedPayload, SerializedObject<T> serializedMetaData) Creates an entity representing a Domain Event, which contains the data provided in the parameters, which can be stored using the JPA Entity Manager configured on the JpaEventStore using this factory.
protected Object	DefaultEventEntryStore.createDomainEventEntry(String aggregateType, DomainEventMessage event, SerializedObject<T> serializedPayload, SerializedObject<T> serializedMetaData) Allows for customization of the DomainEventEntry to store.
Object	DefaultEventEntryFactory.createSnapshotEventEntry(String aggregateType, DomainEventMessage snapshotEvent, SerializedObject<byte[]> serializedPayload, SerializedObject<byte[]> serializedMetaData)
Object	EventEntryFactory.createSnapshotEventEntry(String aggregateType, DomainEventMessage snapshotEvent, SerializedObject<T> serializedPayload, SerializedObject<T> serializedMetaData) Creates an entity representing a Snapshot Event, which contains the data provided in the parameters, which can be stored using the JPA Entity Manager configured on the JpaEventStore using this factory.
protected Object	DefaultEventEntryStore.createSnapshotEventEntry(String aggregateType, DomainEventMessage snapshotEvent, SerializedObject<T> serializedPayload, SerializedObject<T> serializedMetaData) Allows for customization of the SnapshotEventEntry to store.
void	EventEntryStore.persistEvent(String aggregateType, DomainEventMessage event, SerializedObject<T> serializedPayload, SerializedObject<T> serializedMetaData, javax.persistence.EntityManager entityManager) Persists the given event which has been serialized into serializedEvent in the backing data store using given entityManager.
void	DefaultEventEntryStore.persistEvent(String aggregateType, DomainEventMessage event, SerializedObject<T> serializedPayload, SerializedObject<T> serializedMetaData, javax.persistence.EntityManager entityManager)
void	EventEntryStore.persistSnapshot(String aggregateType, DomainEventMessage snapshotEvent, SerializedObject<T> serializedPayload, SerializedObject<T> serializedMetaData, javax.persistence.EntityManager entityManager) Persists the given event which has been serialized into serializedEvent in the backing data store using given entityManager.
void	DefaultEventEntryStore.persistSnapshot(String aggregateType, DomainEventMessage snapshotEvent, SerializedObject<T> serializedPayload, SerializedObject<T> serializedMetaData, javax.persistence.EntityManager entityManager)
void	EventEntryStore.pruneSnapshots(String type, DomainEventMessage mostRecentSnapshotEvent, int maxSnapshotsArchived, javax.persistence.EntityManager entityManager) Removes old snapshots from the storage for an aggregate of given type that generated the given mostRecentSnapshotEvent.
void	DefaultEventEntryStore.pruneSnapshots(String type, DomainEventMessage mostRecentSnapshotEvent, int maxSnapshotsArchived, javax.persistence.EntityManager entityManager)

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

AbstractEventEntry(String type, DomainEventMessage event, org.joda.time.DateTime timestamp, SerializedObject<byte[]> payload, SerializedObject<byte[]> metaData)
Initialize an Event entry for the given event.

AbstractEventEntry(String type, DomainEventMessage event, SerializedObject<byte[]> payload, SerializedObject<byte[]> metaData)
Initialize an Event entry for the given event.

DomainEventEntry(String type, DomainEventMessage event, org.joda.time.DateTime dateTime, SerializedObject<byte[]> payload, SerializedObject<byte[]> metaData)
Initialize an Event entry for the given event.

DomainEventEntry(String type, DomainEventMessage event, SerializedObject<byte[]> payload, SerializedObject<byte[]> metaData)
Initialize an Event entry for the given event.

SnapshotEventEntry(String type, DomainEventMessage event, SerializedObject<byte[]> payload, SerializedObject<byte[]> metaData)
Initialize an Event entry for the given event.

Uses of DomainEventMessage in org.axonframework.eventstore.mongo

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

List<DomainEventMessage>	StorageStrategy.extractEventMessages(com.mongodb.DBObject entry, Object aggregateIdentifier, Serializer serializer, UpcasterChain upcasterChain, boolean skipUnknownTypes) Extracts the individual Event Messages from the given entry.
List<DomainEventMessage>	DocumentPerEventStorageStrategy.extractEventMessages(com.mongodb.DBObject entry, Object aggregateIdentifier, Serializer serializer, UpcasterChain upcasterChain, boolean skipUnknownTypes)
List<DomainEventMessage>	DocumentPerCommitStorageStrategy.extractEventMessages(com.mongodb.DBObject entry, Object aggregateIdentifier, Serializer serializer, UpcasterChain upcasterChain, boolean skipUnknownTypes)

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

void	MongoEventStore.appendSnapshotEvent(String type, DomainEventMessage snapshotEvent)

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

com.mongodb.DBObject[]	StorageStrategy.createDocuments(String type, Serializer eventSerializer, List<DomainEventMessage> messages) Generates the DBObject instances that need to be stored for a commit.
com.mongodb.DBObject[]	DocumentPerEventStorageStrategy.createDocuments(String type, Serializer eventSerializer, List<DomainEventMessage> messages)
com.mongodb.DBObject[]	DocumentPerCommitStorageStrategy.createDocuments(String type, Serializer eventSerializer, List<DomainEventMessage> messages)

Uses of DomainEventMessage in org.axonframework.eventstore.supporting

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

List<DomainEventMessage>

CapturingEventVisitor.visited()

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

void	CapturingEventVisitor.doWithEvent(DomainEventMessage domainEvent)

Uses of DomainEventMessage in org.axonframework.gae.eventstore

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

List<DomainEventMessage>

EventEntry.getDomainEvent(Object actualAggregateIdentifier, Serializer serializer, UpcasterChain upcasterChain, boolean skipUnknownTypes) Returns the actual DomainEvent from the EventEntry using the provided Serializer.

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

void	GaeEventStore.appendSnapshotEvent(String type, DomainEventMessage snapshotEvent)

Uses of DomainEventMessage in org.axonframework.mongo3.eventstore

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

List<DomainEventMessage>	StorageStrategy.extractEventMessages(org.bson.Document entry, Object aggregateIdentifier, Serializer serializer, UpcasterChain upcasterChain, boolean skipUnknownTypes) Extracts the individual Event Messages from the given entry.
List<DomainEventMessage>	DocumentPerEventStorageStrategy.extractEventMessages(org.bson.Document entry, Object aggregateIdentifier, Serializer serializer, UpcasterChain upcasterChain, boolean skipUnknownTypes)
List<DomainEventMessage>	DocumentPerCommitStorageStrategy.extractEventMessages(org.bson.Document entry, Object aggregateIdentifier, Serializer serializer, UpcasterChain upcasterChain, boolean skipUnknownTypes)

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

void	MongoEventStore.appendSnapshotEvent(String type, DomainEventMessage snapshotEvent)

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

List<org.bson.Document>	StorageStrategy.createDocuments(String type, Serializer eventSerializer, List<DomainEventMessage> messages) Generates the DBObject instances that need to be stored for a commit.
List<org.bson.Document>	DocumentPerEventStorageStrategy.createDocuments(String type, Serializer eventSerializer, List<DomainEventMessage> messages)
List<org.bson.Document>	DocumentPerCommitStorageStrategy.createDocuments(String type, Serializer eventSerializer, List<DomainEventMessage> messages)

Uses of DomainEventMessage in org.axonframework.quickstart.handler

Methods in org.axonframework.quickstart.handler with parameters of type DomainEventMessage

protected void

ToDoItem.handle(DomainEventMessage eventMessage)

Uses of DomainEventMessage in org.axonframework.serializer

Classes in org.axonframework.serializer that implement DomainEventMessage

class	SerializationAwareDomainEventMessage<T> Wrapper around a DomainEventMessage that adds "Serialization Awareness" to the message it wraps.
class	SerializedDomainEventMessage<T> DomainEventMessage implementation that is optimized to cope with serialized Payload and MetaData.

Methods in org.axonframework.serializer that return DomainEventMessage

DomainEventMessage<T>	SerializedDomainEventMessage.andMetaData(Map<String,?> additionalMetaData) Returns a copy of this DomainEventMessage with its MetaData merged with the given metaData.
DomainEventMessage<T>	SerializationAwareDomainEventMessage.andMetaData(Map<String,?> metaData)
DomainEventMessage<T>	SerializedDomainEventMessage.withMetaData(Map<String,?> newMetaData)
DomainEventMessage<T>	SerializationAwareDomainEventMessage.withMetaData(Map<String,?> metaData)
static <T> DomainEventMessage<T>	SerializationAwareDomainEventMessage.wrap(DomainEventMessage<T> message) Wrap the given message to make it SerializationAware.

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

static <T> DomainEventMessage<T>

SerializationAwareDomainEventMessage.wrap(DomainEventMessage<T> message) Wrap the given message to make it SerializationAware.

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

SerializationAwareDomainEventMessage(DomainEventMessage<T> message)
Initialize a new wrapper for the given message.

Uses of DomainEventMessage in org.axonframework.test

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

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.

Constructor parameters in org.axonframework.test with type arguments of type DomainEventMessage

ResultValidatorImpl(Collection<DomainEventMessage> storedEvents, Collection<EventMessage> publishedEvents, FieldFilter fieldFilter)
Initialize the ResultValidatorImpl with the given storedEvents and publishedEvents.

Uses of DomainEventMessage in org.axonframework.upcasting

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

static List<DomainEventMessage>

UpcastUtils.upcastAndDeserialize(SerializedDomainEventData entry, Object aggregateIdentifier, Serializer serializer, UpcasterChain upcasterChain, boolean skipUnknownTypes) Upcasts and deserializes the given entry using the given serializer and upcasterChain.