Uses of Interface
org.axonframework.domain.EventMessage

Packages that use EventMessage

Package	Description
org.axonframework.auditing
org.axonframework.commandhandling.disruptor
org.axonframework.domain	The domain components of the Axon Framework, mainly the Aggregates and Events.
org.axonframework.eventhandling	Classes related to event handling and dispatching, such as Event Listeners and the Event Bus.
org.axonframework.eventhandling.annotation	Classes in support of the configuration of Event Handlers using annotations.
org.axonframework.eventhandling.async
org.axonframework.eventhandling.io
org.axonframework.eventhandling.replay
org.axonframework.eventhandling.scheduling.quartz
org.axonframework.saga
org.axonframework.saga.annotation
org.axonframework.serializer
org.axonframework.unitofwork	Classes in support of the UnitOfWork pattern in Axon Framework.

Uses of EventMessage in org.axonframework.auditing

Methods in org.axonframework.auditing that return EventMessage

Modifier and Type	Method and Description
<T> EventMessage<T>	AuditingUnitOfWorkListener.onEventRegistered(UnitOfWork unitOfWork, EventMessage<T> event)

Methods in org.axonframework.auditing with parameters of type EventMessage

Modifier and Type	Method and Description
<T> EventMessage<T>	AuditingUnitOfWorkListener.onEventRegistered(UnitOfWork unitOfWork, EventMessage<T> event)

Method parameters in org.axonframework.auditing with type arguments of type EventMessage

Modifier and Type	Method and Description
void	NullAuditLogger.logFailed(CommandMessage<?> command, Throwable failureCause, List<EventMessage> events) Writes a failure entry to the audit logs.
void	AuditLogger.logFailed(CommandMessage<?> command, Throwable failureCause, List<EventMessage> events) Writes a failure entry to the audit logs.
void	NullAuditLogger.logSuccessful(CommandMessage<?> command, Object returnValue, List<EventMessage> events) Writes a success entry to the audit logs.
void	AuditLogger.logSuccessful(CommandMessage<?> command, Object returnValue, List<EventMessage> events) Writes a success entry to the audit logs.

Uses of EventMessage in org.axonframework.commandhandling.disruptor

Methods in org.axonframework.commandhandling.disruptor that return types with arguments of type EventMessage

Modifier and Type	Method and Description
List<EventMessage>	DisruptorUnitOfWork.getEventsToPublish() Returns the events that need to be published as part of this Unit of Work.

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

Modifier and Type	Method and Description
void	DisruptorUnitOfWork.publishEvent(EventMessage event, EventBus eventBus)

Uses of EventMessage in org.axonframework.domain

Subinterfaces of EventMessage in org.axonframework.domain

Modifier and Type	Interface and Description
interface	DomainEventMessage<T> Represents a Message that wraps a DomainEvent and an Event representing an important change in the Domain.

Classes in org.axonframework.domain that implement EventMessage

Modifier and Type	Class and Description
class	GenericDomainEventMessage<T> Generic implementation of the DomainEventMessage interface.
class	GenericEventMessage<T> Generic implementation of the EventMessage interface.

Methods in org.axonframework.domain that return EventMessage

Modifier and Type	Method and Description
EventMessage<T>	EventMessage.andMetaData(Map<String,?> metaData) Returns a copy of this EventMessage with it MetaData merged with the given metaData.
static <T> EventMessage<T>	GenericEventMessage.asEventMessage(Object event) Returns the given event as an EventMessage.
EventMessage<T>	EventMessage.withMetaData(Map<String,?> metaData) Returns a copy of this EventMessage with the given metaData.

Uses of EventMessage in org.axonframework.eventhandling

Methods in org.axonframework.eventhandling with parameters of type EventMessage

Modifier and Type	Method and Description
void	EventListener.handle(EventMessage event) Process the given event.
void	MultiplexingEventProcessingMonitor.prepare(EventMessage eventMessage) Prepare the monitor for processing the given message.
void	MultiplexingEventProcessingMonitor.prepareForInvocation(EventMessage eventMessage, EventListener member) Prepare the monitor for the invocation of the given message to the given member.
void	SimpleEventBus.publish(EventMessage... events) Publish a collection of events on this bus (one, or multiple).
void	EventBusTerminal.publish(EventMessage... events) Publishes the given events to all clusters on the Event Bus.
void	EventBus.publish(EventMessage... events) Publish a collection of events on this bus (one, or multiple).
void	ClusteringEventBus.publish(EventMessage... events)
void	Cluster.publish(EventMessage... events) Publishes the given Events to the members of this cluster.
void	AbstractCluster.publish(EventMessage... events)

Method parameters in org.axonframework.eventhandling with type arguments of type EventMessage

Modifier and Type	Method and Description
void	SimpleCluster.doPublish(List<EventMessage> events, Set<EventListener> eventListeners, MultiplexingEventProcessingMonitor monitor)
protected abstract void	AbstractCluster.doPublish(List<EventMessage> events, Set<EventListener> eventListeners, MultiplexingEventProcessingMonitor eventProcessingMonitor) Publish the given list of events to the given set of eventListeners, and notify the given eventProcessingMonitor after completion.
void	MultiplexingEventProcessingMonitor.onEventProcessingCompleted(List<? extends EventMessage> eventMessages)
void	EventProcessingMonitorCollection.onEventProcessingCompleted(List<? extends EventMessage> eventMessages)
void	EventProcessingMonitor.onEventProcessingCompleted(List<? extends EventMessage> eventMessages) Invoked when one or more events have been successfully processed by the instance it was subscribed to.
void	MultiplexingEventProcessingMonitor.onEventProcessingFailed(List<? extends EventMessage> eventMessages, Throwable cause)
void	EventProcessingMonitorCollection.onEventProcessingFailed(List<? extends EventMessage> eventMessages, Throwable cause)
void	EventProcessingMonitor.onEventProcessingFailed(List<? extends EventMessage> eventMessages, Throwable cause) Invoked when one or more events have failed processing by the instance it was subscribed to.

Uses of EventMessage in org.axonframework.eventhandling.annotation

Methods in org.axonframework.eventhandling.annotation with parameters of type EventMessage

Modifier and Type	Method and Description
void	AnnotationEventListenerAdapter.handle(EventMessage event) Process the given event.

Uses of EventMessage in org.axonframework.eventhandling.async

Methods in org.axonframework.eventhandling.async with parameters of type EventMessage

Modifier and Type	Method and Description
protected EventProcessor.ProcessingResult	EventProcessor.doHandle(EventMessage<?> event) Does the actual processing of the event.
Object	SequentialPerAggregatePolicy.getSequenceIdentifierFor(EventMessage event) Returns the sequence identifier for the given event.
RetryPolicy	ErrorHandler.handleError(Throwable exception, EventMessage<?> eventMessage, EventListener eventListener) Invoked when a handler or the unit of work throws an exception.
RetryPolicy	DefaultErrorHandler.handleError(Throwable exception, EventMessage<?> eventMessage, EventListener eventListener)
protected void	AsynchronousCluster.schedule(EventMessage<?> task, MultiplexingEventProcessingMonitor eventProcessingMonitor) Schedules this task for execution when all pre-conditions have been met.
boolean	EventProcessor.scheduleEvent(EventMessage<?> event) Schedules an event for processing.

Method parameters in org.axonframework.eventhandling.async with type arguments of type EventMessage

Modifier and Type	Method and Description
protected void	AsynchronousCluster.doPublish(List<EventMessage> events, Set<EventListener> eventListeners, MultiplexingEventProcessingMonitor eventProcessingMonitor)

Constructor parameters in org.axonframework.eventhandling.async with type arguments of type EventMessage

Constructor and Description
AsynchronousCluster(String identifier, Executor executor, SequencingPolicy<? super EventMessage<?>> sequencingPolicy) Creates an AsynchronousCluster implementation using the given executor and sequencingPolicy.
AsynchronousCluster(String identifier, Executor executor, TransactionManager transactionManager, SequencingPolicy<? super EventMessage<?>> sequencingPolicy) Creates an AsynchronousCluster implementation using the given executor, transactionManager and sequencingPolicy.
AsynchronousCluster(String identifier, Executor executor, TransactionManager transactionManager, SequencingPolicy<? super EventMessage<?>> sequencingPolicy, ErrorHandler errorHandler) Creates an AsynchronousCluster implementation using the given executor, transactionManager and sequencingPolicy.
AsynchronousCluster(String name, Executor executor, UnitOfWorkFactory unitOfWorkFactory, SequencingPolicy<? super EventMessage<?>> sequencingPolicy, ErrorHandler errorHandler) Creates an AsynchronousCluster implementation using the given executor, unitOfWorkFactory and sequencingPolicy.
AsynchronousCluster(String name, Executor executor, UnitOfWorkFactory unitOfWorkFactory, SequencingPolicy<? super EventMessage<?>> sequencingPolicy, ErrorHandler errorHandler, OrderResolver orderResolver) Creates an AsynchronousCluster implementation using the given executor, unitOfWorkFactory and sequencingPolicy.

Uses of EventMessage in org.axonframework.eventhandling.io

Methods in org.axonframework.eventhandling.io that return EventMessage

Modifier and Type	Method and Description
<T> EventMessage<T>	EventMessageReader.readEventMessage() Reads an EventMessage from the underlying input.

Methods in org.axonframework.eventhandling.io with parameters of type EventMessage

Modifier and Type	Method and Description
static EventMessageType	EventMessageType.forMessage(EventMessage message) Returns the most specific EventMessageType for the given message.
void	EventMessageWriter.writeEventMessage(EventMessage eventMessage) Writes the given eventMessage to the underling output.

Uses of EventMessage in org.axonframework.eventhandling.replay

Methods in org.axonframework.eventhandling.replay that return types with arguments of type EventMessage

Modifier and Type	Method and Description
List<EventMessage>	IncomingMessageHandler.onIncomingMessages(Cluster destination, EventMessage... messages) Invoked while the ReplayingCluster is in replay mode and an Event is being dispatched to the Cluster.
List<EventMessage>	DiscardingIncomingMessageHandler.onIncomingMessages(Cluster destination, EventMessage... messages)
List<EventMessage>	BackloggingIncomingMessageHandler.onIncomingMessages(Cluster destination, EventMessage... messages)
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)

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

Modifier and Type	Method and Description
List<EventMessage>	IncomingMessageHandler.onIncomingMessages(Cluster destination, EventMessage... messages) Invoked while the ReplayingCluster is in replay mode and an Event is being dispatched to the Cluster.
List<EventMessage>	DiscardingIncomingMessageHandler.onIncomingMessages(Cluster destination, EventMessage... messages)
List<EventMessage>	BackloggingIncomingMessageHandler.onIncomingMessages(Cluster destination, EventMessage... messages)
void	ReplayingCluster.publish(EventMessage... events)

Constructor parameters in org.axonframework.eventhandling.replay with type arguments of type EventMessage

Constructor and Description
BackloggingIncomingMessageHandler(org.joda.time.Duration backlogThresholdMargin, Queue<EventMessage> backlog) Creates a new BackloggingIncomingMessageHandler.

Uses of EventMessage in org.axonframework.eventhandling.scheduling.quartz

Methods in org.axonframework.eventhandling.scheduling.quartz with parameters of type EventMessage

Modifier and Type	Method and Description
protected org.quartz.JobDetail	QuartzEventScheduler.buildJobDetail(EventMessage event, org.quartz.JobKey jobKey) Builds the JobDetail instance for Quartz, which defines the Job that needs to be executed when the trigger fires.

Uses of EventMessage in org.axonframework.saga

Methods in org.axonframework.saga with parameters of type EventMessage

Modifier and Type	Method and Description
protected Set<AssociationValue>	SimpleSagaManager.extractAssociationValues(Class<? extends Saga> type, EventMessage event)
protected abstract Set<AssociationValue>	AbstractSagaManager.extractAssociationValues(Class<? extends Saga> sagaType, EventMessage event) Extracts the AssociationValues from the given event as relevant for a Saga of given sagaType.
Set<AssociationValue>	AssociationValueResolver.extractAssociationValues(EventMessage event) Extracts an Association Value from the given event.
protected SagaInitializationPolicy	SimpleSagaManager.getSagaCreationPolicy(Class<? extends Saga> type, EventMessage event)
protected abstract SagaInitializationPolicy	AbstractSagaManager.getSagaCreationPolicy(Class<? extends Saga> sagaType, EventMessage event) Returns the Saga Initialization Policy for a Saga of the given sagaType and event.
void	SagaManager.handle(EventMessage event) Handles the event by passing it to all Saga instances that have an Association Value found in the given event.
void	Saga.handle(EventMessage event) Handle the given event.
void	AbstractSagaManager.handle(EventMessage event)
protected AssociationValue	SimpleSagaManager.initialAssociationValue(EventMessage event) Returns the association value to assign to a Saga when the given event triggers the creation of a new instance.

Method parameters in org.axonframework.saga with type arguments of type EventMessage

Modifier and Type	Method and Description
void	AbstractSagaManager.setCorrelationDataProvider(CorrelationDataProvider<? super EventMessage> correlationDataProvider) Sets the correlation data provider for this SagaManager.
void	AbstractSagaManager.setCorrelationDataProviders(List<? extends CorrelationDataProvider<? super EventMessage>> correlationDataProviders) Sets the given correlationDataProviders.

Uses of EventMessage in org.axonframework.saga.annotation

Methods in org.axonframework.saga.annotation that return EventMessage

Modifier and Type	Method and Description
EventMessage	AsyncSagaProcessingEvent.getPublishedEvent() Returns the event that has been published on the EventBus.

Methods in org.axonframework.saga.annotation with parameters of type EventMessage

Modifier and Type	Method and Description
protected Set<AssociationValue>	AnnotatedSagaManager.extractAssociationValues(Class<? extends Saga> sagaType, EventMessage event)
SagaMethodMessageHandler	SagaMethodMessageHandlerInspector.findHandlerMethod(AbstractAnnotatedSaga target, EventMessage event) Finds the handler method on given target for the given event.
AssociationValue	SagaMethodMessageHandler.getAssociationValue(EventMessage eventMessage) The AssociationValue to find the saga instance with, or null if no AssociationValue can be found on the given eventMessage.
List<SagaMethodMessageHandler>	SagaMethodMessageHandlerInspector.getMessageHandlers(EventMessage event) Find the configuration for the handlers for the given event.
protected SagaInitializationPolicy	AnnotatedSagaManager.getSagaCreationPolicy(Class<? extends Saga> sagaType, EventMessage event)
void	AsyncAnnotatedSagaManager.handle(EventMessage event)
void	AbstractAnnotatedSaga.handle(EventMessage event)
void	SagaMethodMessageHandler.invoke(Object target, EventMessage message) Invoke a handler on given target for given message.
boolean	SagaMethodMessageHandler.matches(EventMessage message) Indicates whether this Handler is suitable for the given message.
RetryPolicy	RetryingErrorHandler.onErrorInvoking(Saga saga, EventMessage publishedEvent, int invocationCount, Exception e)
RetryPolicy	ProceedingErrorHandler.onErrorInvoking(Saga saga, EventMessage publishedEvent, int invocationCount, Exception e)
RetryPolicy	ErrorHandler.onErrorInvoking(Saga saga, EventMessage publishedEvent, int invocationCount, Exception exception) Invoked when an error occurs when a Saga instance is invoked.
RetryPolicy	RetryingErrorHandler.onErrorPreparing(Class<? extends Saga> sagaType, EventMessage<?> publishedEvent, int invocationCount, Exception e)
RetryPolicy	ProceedingErrorHandler.onErrorPreparing(Class<? extends Saga> sagaType, EventMessage<?> publishedEvent, int invocationCount, Exception e)
RetryPolicy	ErrorHandler.onErrorPreparing(Class<? extends Saga> sagaType, EventMessage<?> publishedEvent, int invocationCount, Exception exception) Invoked when an error occurs preparing Sagas.
void	AsyncSagaProcessingEvent.reset(EventMessage nextEvent, Class<? extends AbstractAnnotatedSaga> nextSagaType, List<SagaMethodMessageHandler> nextHandlers, AbstractAnnotatedSaga nextSagaInstance) Reset this entry for processing a new EventMessage

Method parameters in org.axonframework.saga.annotation with type arguments of type EventMessage

Modifier and Type	Method and Description
void	AsyncAnnotatedSagaManager.setCorrelationDataProvider(CorrelationDataProvider<? super EventMessage> correlationDataProvider) Sets the CorrelationDataProvider which provides the Meta Data to assign to messages generated by the Sagas that are managed by this SagaManager instance.
void	AsyncAnnotatedSagaManager.setCorrelationDataProviders(List<? extends CorrelationDataProvider<? super EventMessage>> correlationDataProviders) Sets the CorrelationDataProviders which provide the Meta Data to assign to messages generated by the Sagas that are managed by this SagaManager instance.

Uses of EventMessage in org.axonframework.serializer

Classes in org.axonframework.serializer that implement EventMessage

Modifier and Type	Class and Description
class	SerializationAwareDomainEventMessage<T> Wrapper around a DomainEventMessage that adds "Serialization Awareness" to the message it wraps.
class	SerializationAwareEventMessage<T> Wrapper around am EventMessage that adds "Serialization Awareness" to the message it wraps.
class	SerializedDomainEventMessage<T> DomainEventMessage implementation that is optimized to cope with serialized Payload and MetaData.
class	SerializedEventMessage<T> EventMessage implementation that is optimized to cope with serialized Payload and MetaData.

Methods in org.axonframework.serializer that return EventMessage

Modifier and Type	Method and Description
EventMessage<T>	SerializedEventMessage.andMetaData(Map<String,?> additionalMetaData)
EventMessage<T>	SerializationAwareEventMessage.andMetaData(Map<String,?> metaData)
EventMessage<T>	SerializationAwareEventMessage.withMetaData(Map<String,?> metaData)
static <T> EventMessage<T>	SerializationAwareEventMessage.wrap(EventMessage<T> message) Wrap the given message to make it SerializationAware.

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

Modifier and Type	Method and Description
static <T> EventMessage<T>	SerializationAwareEventMessage.wrap(EventMessage<T> message) Wrap the given message to make it SerializationAware.

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

Constructor and Description
SerializationAwareEventMessage(EventMessage<T> eventMessage) Initializes a new wrapper for the given eventMessage.

Uses of EventMessage in org.axonframework.unitofwork

Methods in org.axonframework.unitofwork that return EventMessage

Modifier and Type	Method and Description
<T> EventMessage<T>	UnitOfWorkListenerCollection.onEventRegistered(UnitOfWork unitOfWork, EventMessage<T> event) Invoked when an Event is registered for publication when the UnitOfWork is committed.
<T> EventMessage<T>	UnitOfWorkListenerAdapter.onEventRegistered(UnitOfWork unitOfWork, EventMessage<T> event) Invoked when an Event is registered for publication when the UnitOfWork is committed.
<T> EventMessage<T>	UnitOfWorkListener.onEventRegistered(UnitOfWork unitOfWork, EventMessage<T> event) Invoked when an Event is registered for publication when the UnitOfWork is committed.
<T> EventMessage<T>	MetaDataMutatingUnitOfWorkListenerAdapter.onEventRegistered(UnitOfWork unitOfWork, EventMessage<T> event)

Methods in org.axonframework.unitofwork with parameters of type EventMessage

Modifier and Type	Method and Description
protected abstract Map<String,?>	MetaDataMutatingUnitOfWorkListenerAdapter.assignMetaData(EventMessage event, List<EventMessage> events, int index) Defines the additional meta data to assign to the given event.
<T> EventMessage<T>	UnitOfWorkListenerCollection.onEventRegistered(UnitOfWork unitOfWork, EventMessage<T> event) Invoked when an Event is registered for publication when the UnitOfWork is committed.
<T> EventMessage<T>	UnitOfWorkListenerAdapter.onEventRegistered(UnitOfWork unitOfWork, EventMessage<T> event) Invoked when an Event is registered for publication when the UnitOfWork is committed.
<T> EventMessage<T>	UnitOfWorkListener.onEventRegistered(UnitOfWork unitOfWork, EventMessage<T> event) Invoked when an Event is registered for publication when the UnitOfWork is committed.
<T> EventMessage<T>	MetaDataMutatingUnitOfWorkListenerAdapter.onEventRegistered(UnitOfWork unitOfWork, EventMessage<T> event)
void	UnitOfWork.publishEvent(EventMessage<?> event, EventBus eventBus) Request to publish the given event on the given eventBus.
void	NestableUnitOfWork.publishEvent(EventMessage<?> event, EventBus eventBus)
protected abstract void	NestableUnitOfWork.registerForPublication(EventMessage<?> event, EventBus eventBus, boolean notifyRegistrationHandlers) Register the given event for publication on the given eventBus when the unit of work is committed.
void	DefaultUnitOfWork.registerForPublication(EventMessage<?> event, EventBus eventBus, boolean notifyRegistrationHandlers)

Method parameters in org.axonframework.unitofwork with type arguments of type EventMessage

Modifier and Type	Method and Description
protected abstract Map<String,?>	MetaDataMutatingUnitOfWorkListenerAdapter.assignMetaData(EventMessage event, List<EventMessage> events, int index) Defines the additional meta data to assign to the given event.
void	UnitOfWorkListenerCollection.onPrepareCommit(UnitOfWork unitOfWork, Set<AggregateRoot> aggregateRoots, List<EventMessage> events) Invoked before aggregates are committed, and before any events are published.
void	UnitOfWorkListenerAdapter.onPrepareCommit(UnitOfWork unitOfWork, Set<AggregateRoot> aggregateRoots, List<EventMessage> events) Invoked before aggregates are committed, and before any events are published.
void	UnitOfWorkListener.onPrepareCommit(UnitOfWork unitOfWork, Set<AggregateRoot> aggregateRoots, List<EventMessage> events) Invoked before aggregates are committed, and before any events are published.
void	MetaDataMutatingUnitOfWorkListenerAdapter.onPrepareCommit(UnitOfWork unitOfWork, Set<AggregateRoot> aggregateRoots, List<EventMessage> events)