Uses of Interface
org.axonframework.eventhandling.EventMessage

Packages that use EventMessage

Package	Description
org.axonframework.axonserver.connector.event.axon
org.axonframework.config
org.axonframework.deadline
org.axonframework.eventhandling	Classes related to event handling and dispatching, such as Event Listeners and the Event Bus.
org.axonframework.eventhandling.async
org.axonframework.eventhandling.gateway
org.axonframework.eventhandling.interceptors
org.axonframework.eventhandling.scheduling.quartz
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.messaging	Classes related to message processing in Axon Framework.
org.axonframework.metrics
org.axonframework.micrometer
org.axonframework.modelling.command.inspection
org.axonframework.modelling.saga
org.axonframework.modelling.saga.metamodel
org.axonframework.spring.messaging	Utility classes used to connect Axon Event publishing mechanisms to a Spring Messaging Channel.
org.axonframework.test.aggregate
org.axonframework.test.eventscheduler
org.axonframework.test.matchers
org.axonframework.test.saga

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

Method parameters in org.axonframework.axonserver.connector.event.axon with type arguments of type EventMessage

Modifier and Type	Method and Description
AxonServerEventStore.Builder	AxonServerEventStore.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor)

Uses of EventMessage in org.axonframework.config

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

Modifier and Type	Method and Description
List<MessageHandlerInterceptor<? super EventMessage<?>>>	EventProcessingModule.interceptorsFor(String processorName)
List<MessageHandlerInterceptor<? super EventMessage<?>>>	EventProcessingConfiguration.interceptorsFor(String processorName) Returns a List of MessageHandlerInterceptors for a processor with given processorName.
SequencingPolicy<? super EventMessage<?>>	EventProcessingModule.sequencingPolicy(String processingGroup)
SequencingPolicy<? super EventMessage<?>>	EventProcessingConfiguration.sequencingPolicy(String processingGroup) Returns the SequencingPolicy tied to the given processingGroup.

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

Modifier and Type	Method and Description
EventProcessingConfigurer	EventProcessingModule.configureDefaultSubscribableMessageSource(Function<Configuration,SubscribableMessageSource<EventMessage<?>>> defaultSource)
EventProcessingConfigurer	EventProcessingConfigurer.configureDefaultSubscribableMessageSource(Function<Configuration,SubscribableMessageSource<EventMessage<?>>> defaultSource) Configures which SubscribableMessageSource to use for Subscribing Event Processors if none was explicitly provided.
EventProcessingConfigurer	EventProcessingModule.registerDefaultHandlerInterceptor(BiFunction<Configuration,String,MessageHandlerInterceptor<? super EventMessage<?>>> interceptorBuilder)
EventProcessingConfigurer	EventProcessingConfigurer.registerDefaultHandlerInterceptor(BiFunction<Configuration,String,MessageHandlerInterceptor<? super EventMessage<?>>> interceptorBuilder) Register the given interceptorBuilder as a default to build a MessageHandlerInterceptor for EventProcessors created in this configuration.
EventProcessingConfigurer	EventProcessingModule.registerDefaultSequencingPolicy(Function<Configuration,SequencingPolicy<? super EventMessage<?>>> policyBuilder)
EventProcessingConfigurer	EventProcessingConfigurer.registerDefaultSequencingPolicy(Function<Configuration,SequencingPolicy<? super EventMessage<?>>> policyBuilder) Registers the SequencingPolicy created by given policyBuilder to the processing groups for which no explicit policy is defined (using EventProcessingConfigurer.registerSequencingPolicy(String, Function)).
EventProcessingConfigurer	EventProcessingModule.registerHandlerInterceptor(String processorName, Function<Configuration,MessageHandlerInterceptor<? super EventMessage<?>>> interceptorBuilder)
EventProcessingConfigurer	EventProcessingConfigurer.registerHandlerInterceptor(String processorName, Function<Configuration,MessageHandlerInterceptor<? super EventMessage<?>>> interceptorBuilder) Register the given interceptorBuilder to build a MessageHandlerInterceptor for the EventProcessor with given processorName.
EventProcessingConfigurer	EventProcessingModule.registerSequencingPolicy(String processingGroup, Function<Configuration,SequencingPolicy<? super EventMessage<?>>> policyBuilder)
EventProcessingConfigurer	EventProcessingConfigurer.registerSequencingPolicy(String processingGroup, Function<Configuration,SequencingPolicy<? super EventMessage<?>>> policyBuilder) Registers the SequencingPolicy created by the given policyBuilder to the processing group with given processingGroup.
EventProcessingConfigurer	EventProcessingModule.registerSubscribingEventProcessor(String name, Function<Configuration,SubscribableMessageSource<? extends EventMessage<?>>> messageSource)
EventProcessingConfigurer	EventProcessingConfigurer.registerSubscribingEventProcessor(String name, Function<Configuration,SubscribableMessageSource<? extends EventMessage<?>>> messageSource) Registers a SubscribingEventProcessor with given name and messageSource within this Configuration.

Uses of EventMessage in org.axonframework.deadline

Subinterfaces of EventMessage in org.axonframework.deadline

Modifier and Type	Interface and Description
interface	DeadlineMessage<T> Represents a Message for a Deadline, specified by its deadline name and optionally containing a deadline payload.

Classes in org.axonframework.deadline that implement EventMessage

Modifier and Type	Class and Description
class	GenericDeadlineMessage<T> Generic implementation of the DeadlineMessage.

Uses of EventMessage in org.axonframework.eventhandling

Subinterfaces of EventMessage in org.axonframework.eventhandling

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.
interface	TrackedEventMessage<T> Represents an EventMessage containing a TrackingToken.

Classes in org.axonframework.eventhandling that implement EventMessage

Modifier and Type	Class and Description
class	GenericDomainEventMessage<T> Generic implementation of a DomainEventMessage.
class	GenericEventMessage<T> Generic implementation of the EventMessage interface.
class	GenericTrackedDomainEventMessage<T> Generic implementation of a DomainEventMessage that is also a TrackedEventMessage.
class	GenericTrackedEventMessage<T> Generic implementation of a TrackedEventMessage.

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

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

Modifier and Type	Method and Description
List<? extends EventMessage<?>>	ErrorContext.failedEvents() The events part of the batch that failed.
List<MessageHandlerInterceptor<? super EventMessage<?>>>	AbstractEventProcessor.getHandlerInterceptors()
List<MessageHandlerInterceptor<? super EventMessage<?>>>	EventProcessor.getHandlerInterceptors() Return the list of already registered MessageHandlerInterceptors for this event processor.
SubscribableMessageSource<? extends EventMessage<?>>	SubscribingEventProcessor.getMessageSource() Returns the message source from which this processor receives its events
SequencingPolicy<? super EventMessage<?>>	SimpleEventHandlerInvoker.getSequencingPolicy()
protected List<? extends EventMessage<?>>	AbstractEventBus.intercept(List<? extends EventMessage<?>> events) Invokes all the dispatch interceptors.
protected List<EventMessage<?>>	AbstractEventBus.queuedMessages() Returns a list of all the events staged for publication in this Unit of Work.

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

Modifier and Type	Method and Description
static <T> DomainEventMessage<T>	EventUtils.asDomainEventMessage(EventMessage<T> eventMessage) Convert a plain EventMessage to a DomainEventMessage.
static <T> TrackedEventMessage<T>	EventUtils.asTrackedEventMessage(EventMessage<T> eventMessage, TrackingToken trackingToken) Convert an EventMessage to a TrackedEventMessage using the given trackingToken.
boolean	AnnotationEventHandlerAdapter.canHandle(EventMessage<?> event)
protected boolean	TrackingEventProcessor.canHandle(EventMessage<?> eventMessage, Collection<Segment> segments) Indicates whether any of the components handling events for this Processor are able to handle the given eventMessage for any of the given segments.
boolean	SimpleEventHandlerInvoker.canHandle(EventMessage<?> eventMessage, Segment segment)
protected boolean	AbstractEventProcessor.canHandle(EventMessage<?> eventMessage, Segment segment) Indicates whether the processor can/should handle the given eventMessage for the given segment.
boolean	MultiEventHandlerInvoker.canHandle(EventMessage<?> eventMessage, Segment segment)
boolean	EventHandlerInvoker.canHandle(EventMessage<?> eventMessage, Segment segment) Check whether or not this invoker has handlers that can handle the given eventMessage for a given segment.
Object	EventMessageHandler.handle(EventMessage<?> event) Process the given event.
Object	AnnotationEventHandlerAdapter.handle(EventMessage<?> event)
void	SimpleEventHandlerInvoker.handle(EventMessage<?> message, Segment segment)
void	MultiEventHandlerInvoker.handle(EventMessage<?> message, Segment segment)
void	EventHandlerInvoker.handle(EventMessage<?> message, Segment segment) Handle the given message for the given segment.
void	PropagatingErrorHandler.onError(Exception exception, EventMessage<?> event, EventMessageHandler eventHandler)
void	LoggingErrorHandler.onError(Exception exception, EventMessage<?> event, EventMessageHandler eventHandler)
void	ListenerInvocationErrorHandler.onError(Exception exception, EventMessage<?> event, EventMessageHandler eventHandler) Invoked after given eventListener failed to handle given event.
default void	EventBus.publish(EventMessage<?>... events) Publish a collection of events on this bus (one, or multiple).
protected void	AbstractEventProcessor.reportIgnored(EventMessage<?> eventMessage) Report the given eventMessage as ignored.

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

Modifier and Type	Method and Description
protected void	AbstractEventBus.afterCommit(List<? extends EventMessage<?>> events) Process given events after the Unit of Work has been committed.
protected void	AbstractEventBus.commit(List<? extends EventMessage<?>> events) Process given events while the Unit of Work root is being committed.
void	EventProcessingStrategy.handle(List<? extends EventMessage<?>> events, Consumer<List<? extends EventMessage<?>>> processor) Handle the given batch of events.
void	EventProcessingStrategy.handle(List<? extends EventMessage<?>> events, Consumer<List<? extends EventMessage<?>>> processor) Handle the given batch of events.
void	DirectEventProcessingStrategy.handle(List<? extends EventMessage<?>> events, Consumer<List<? extends EventMessage<?>>> processor)
void	DirectEventProcessingStrategy.handle(List<? extends EventMessage<?>> events, Consumer<List<? extends EventMessage<?>>> processor)
protected List<? extends EventMessage<?>>	AbstractEventBus.intercept(List<? extends EventMessage<?>> events) Invokes all the dispatch interceptors.
SubscribingEventProcessor.Builder	SubscribingEventProcessor.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor)
TrackingEventProcessor.Builder	TrackingEventProcessor.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor)
AbstractEventProcessor.Builder	AbstractEventProcessor.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor) Sets the MessageMonitor to monitor EventMessages before and after they're processed.
SimpleEventBus.Builder	SimpleEventBus.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor)
AbstractEventBus.Builder	AbstractEventBus.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor) Sets the MessageMonitor to monitor ingested EventMessages.
SubscribingEventProcessor.Builder	SubscribingEventProcessor.Builder.messageSource(SubscribableMessageSource<? extends EventMessage<?>> messageSource) Sets the SubscribableMessageSource (e.g.
protected void	AbstractEventBus.prepareCommit(List<? extends EventMessage<?>> events) Process given events while the Unit of Work root is preparing for commit.
protected void	SubscribingEventProcessor.process(List<? extends EventMessage<?>> eventMessages) Process the given messages.
protected void	AbstractEventProcessor.processInUnitOfWork(List<? extends EventMessage<?>> eventMessages, UnitOfWork<? extends EventMessage<?>> unitOfWork) Process a batch of events.
protected void	AbstractEventProcessor.processInUnitOfWork(List<? extends EventMessage<?>> eventMessages, UnitOfWork<? extends EventMessage<?>> unitOfWork) Process a batch of events.
protected void	AbstractEventProcessor.processInUnitOfWork(List<? extends EventMessage<?>> eventMessages, UnitOfWork<? extends EventMessage<?>> unitOfWork, Collection<Segment> processingSegments) Process a batch of events.
protected void	AbstractEventProcessor.processInUnitOfWork(List<? extends EventMessage<?>> eventMessages, UnitOfWork<? extends EventMessage<?>> unitOfWork, Collection<Segment> processingSegments) Process a batch of events.
void	EventBus.publish(List<? extends EventMessage<?>> events) Publish a collection of events on this bus (one, or multiple).
void	AbstractEventBus.publish(List<? extends EventMessage<?>> events)
Registration	EventBus.registerDispatchInterceptor(MessageDispatchInterceptor<? super EventMessage<?>> dispatchInterceptor) Register the given interceptor with this bus.
Registration	AbstractEventBus.registerDispatchInterceptor(MessageDispatchInterceptor<? super EventMessage<?>> dispatchInterceptor) Register the given interceptor with this bus.
Registration	AbstractEventProcessor.registerHandlerInterceptor(MessageHandlerInterceptor<? super EventMessage<?>> interceptor)
SimpleEventHandlerInvoker.Builder	SimpleEventHandlerInvoker.Builder.sequencingPolicy(SequencingPolicy<? super EventMessage<?>> sequencingPolicy) Sets the SequencingPolicy in charge of deciding whether a given event should be handled (through SimpleEventHandlerInvoker.handle(EventMessage, Segment)) by the given Segment.
Registration	AbstractEventBus.subscribe(Consumer<List<? extends EventMessage<?>>> eventProcessor)

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

Constructor and Description
AbstractEventEntry(EventMessage<?> eventMessage, Serializer serializer, Class<T> contentType) Construct a new event entry from a published event message to enable storing the event or sending it to a remote location.
GenericTrackedEventMessage(TrackingToken trackingToken, EventMessage<T> delegate) Creates a GenericTrackedEventMessage with given trackingToken and delegate event message.

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

Constructor and Description
ErrorContext(String eventProcessor, Throwable error, List<? extends EventMessage<?>> failedEvents) Instantiate an ErrorContext for the given eventProcessor, due to the given error, with the given failedEvents.

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
Object	SequentialPerAggregatePolicy.getSequenceIdentifierFor(EventMessage event)
Object	FullConcurrencyPolicy.getSequenceIdentifierFor(EventMessage<?> event)

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

Modifier and Type	Method and Description
void	AsynchronousEventProcessingStrategy.handle(List<? extends EventMessage<?>> events, Consumer<List<? extends EventMessage<?>>> processor)
void	AsynchronousEventProcessingStrategy.handle(List<? extends EventMessage<?>> events, Consumer<List<? extends EventMessage<?>>> processor)
protected void	AsynchronousEventProcessingStrategy.schedule(List<? extends EventMessage<?>> events, Consumer<List<? extends EventMessage<?>>> processor) Schedules this task for execution when all pre-conditions have been met.
protected void	AsynchronousEventProcessingStrategy.schedule(List<? extends EventMessage<?>> events, Consumer<List<? extends EventMessage<?>>> processor) Schedules this task for execution when all pre-conditions have been met.
boolean	EventProcessorTask.scheduleEvents(List<? extends EventMessage<?>> events, Consumer<List<? extends EventMessage<?>>> processor) Schedules a batch of events for processing.
boolean	EventProcessorTask.scheduleEvents(List<? extends EventMessage<?>> events, Consumer<List<? extends EventMessage<?>>> processor) Schedules a batch of events for processing.

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

Constructor and Description
AsynchronousEventProcessingStrategy(Executor executor, SequencingPolicy<? super EventMessage<?>> sequencingPolicy) Initializes a new AsynchronousEventProcessingStrategy that uses the given executor to execute event processing tasks and sequencingPolicy that determines if an event may be processed in sequence or in parallel.

Uses of EventMessage in org.axonframework.eventhandling.gateway

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

Modifier and Type	Method and Description
protected <E> EventMessage<? extends E>	AbstractEventGateway.processInterceptors(EventMessage<E> eventMessage) Invokes all the dispatch interceptors and returns the EventMessage instance that should be dispatched.

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

Modifier and Type	Method and Description
protected <E> EventMessage<? extends E>	AbstractEventGateway.processInterceptors(EventMessage<E> eventMessage) Invokes all the dispatch interceptors and returns the EventMessage instance that should be dispatched.

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

Modifier and Type	Method and Description
AbstractEventGateway.Builder	AbstractEventGateway.Builder.dispatchInterceptors(List<MessageDispatchInterceptor<? super EventMessage<?>>> dispatchInterceptors) Sets the List of MessageDispatchInterceptors for EventMessages.
DefaultEventGateway.Builder	DefaultEventGateway.Builder.dispatchInterceptors(List<MessageDispatchInterceptor<? super EventMessage<?>>> dispatchInterceptors)
Registration	AbstractEventGateway.registerDispatchInterceptor(MessageDispatchInterceptor<? super EventMessage<?>> interceptor) Registers an event dispatch interceptor within an EventGateway.

Uses of EventMessage in org.axonframework.eventhandling.interceptors

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

Modifier and Type	Method and Description
BiFunction<Integer,EventMessage<?>,EventMessage<?>>	EventLoggingInterceptor.handle(List<? extends EventMessage<?>> messages)
BiFunction<Integer,EventMessage<?>,EventMessage<?>>	EventLoggingInterceptor.handle(List<? extends EventMessage<?>> messages)

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

Modifier and Type	Method and Description
BiFunction<Integer,EventMessage<?>,EventMessage<?>>	EventLoggingInterceptor.handle(List<? extends EventMessage<?>> messages)

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

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

Modifier and Type	Method and Description
void	FilteringEventStorageEngine.appendEvents(EventMessage<?>... events)
void	SnapshotTrigger.eventHandled(EventMessage<?> msg) Invoked when an event is handled by an aggregate.
protected void	EventSourcedAggregate.publish(EventMessage<?> msg)
protected void	EventSourcedAggregate.publishOnEventBus(EventMessage<?> msg)

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

Modifier and Type	Method and Description
void	FilteringEventStorageEngine.appendEvents(List<? extends EventMessage<?>> events)

Constructor parameters in org.axonframework.eventsourcing with type arguments of type EventMessage

Constructor and Description
FilteringEventStorageEngine(EventStorageEngine delegate, Predicate<? super EventMessage<?>> filter) Initializes the FilteringEventStorageEngine delegating all event messages matching the given filter to the given delegate.

Uses of EventMessage in org.axonframework.eventsourcing.conflictresolution

Methods in org.axonframework.eventsourcing.conflictresolution with type parameters of type EventMessage

Modifier and Type	Method and Description
static <T extends EventMessage<?>> Predicate<List<T>>	Conflicts.eventMatching(Predicate<? super T> messageFilter) Returns a Predicate for a ConflictResolver that responds affirmative if any event in a list of unseen events matches the given messageFilter.

Uses of EventMessage in org.axonframework.eventsourcing.eventstore

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

Modifier and Type	Method and Description
default void	EventStorageEngine.appendEvents(EventMessage<?>... events) Append one or more events to the event storage.
protected void	AbstractEventStorageEngine.handlePersistenceException(Exception exception, EventMessage<?> failedEvent) Invoke when an Exception is raised while persisting an Event or Snapshot.

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

Modifier and Type	Method and Description
protected void	EmbeddedEventStore.afterCommit(List<? extends EventMessage<?>> events)
void	EventStorageEngine.appendEvents(List<? extends EventMessage<?>> events) Append a list of events to the event storage.
void	SequenceEventStorageEngine.appendEvents(List<? extends EventMessage<?>> events)
void	AbstractEventStorageEngine.appendEvents(List<? extends EventMessage<?>> events)
protected abstract void	AbstractEventStorageEngine.appendEvents(List<? extends EventMessage<?>> events, Serializer serializer) Append given events to the backing database.
AbstractEventStore.Builder	AbstractEventStore.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor)
EmbeddedEventStore.Builder	EmbeddedEventStore.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor)
protected void	AbstractEventStore.prepareCommit(List<? extends EventMessage<?>> events)

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

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

Modifier and Type	Method and Description
void	InMemoryEventStorageEngine.appendEvents(List<? extends EventMessage<?>> events)

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

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

Modifier and Type	Method and Description
protected PreparedStatement	JdbcEventStorageEngine.appendEvents(Connection connection, List<? extends EventMessage<?>> events, Serializer serializer) Creates a statement to be used at JdbcEventStorageEngine.appendEvents(List, Serializer).
protected void	JdbcEventStorageEngine.appendEvents(List<? extends EventMessage<?>> events, Serializer serializer)

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

Method parameters in org.axonframework.eventsourcing.eventstore.jdbc.statements with type arguments of type EventMessage

Modifier and Type	Method and Description
static PreparedStatement	JdbcEventStorageEngineStatements.appendEvents(Connection connection, EventSchema schema, Class<?> dataType, List<? extends EventMessage<?>> events, Serializer serializer, TimestampWriter timestampWriter) Set the PreparedStatement to be used on JdbcEventStorageEngine.appendEvents(List, Serializer).
PreparedStatement	AppendEventsStatementBuilder.build(Connection connection, EventSchema schema, Class<?> dataType, List<? extends EventMessage<?>> events, Serializer serializer, TimestampWriter timestampWriter) Build a statement to be used at JdbcEventStorageEngine.appendEvents(List, Serializer)

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

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

Modifier and Type	Method and Description
protected Object	JpaEventStorageEngine.createEventEntity(EventMessage<?> eventMessage, Serializer serializer) Returns a Jpa event entity for given eventMessage.

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

Modifier and Type	Method and Description
protected void	JpaEventStorageEngine.appendEvents(List<? extends EventMessage<?>> events, Serializer serializer)

Uses of EventMessage in org.axonframework.messaging

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

Modifier and Type	Method and Description
static Map<String,Object>	Headers.defaultHeaders(EventMessage<?> message, SerializedObject<?> serializedObject) Generate defaults headers to recognise an event message.

Uses of EventMessage in org.axonframework.metrics

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

Modifier and Type	Method and Description
MessageMonitor<? super EventMessage<?>>	GlobalMetricRegistry.registerEventBus(String eventBusName) Registers new metrics to the registry to monitor an EventBus.
MessageMonitor<? super EventMessage<?>>	GlobalMetricRegistry.registerEventProcessor(String eventProcessorName) Registers new metrics to the registry to monitor an EventProcessor.

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

Modifier and Type	Method and Description
MessageMonitor.MonitorCallback	EventProcessorLatencyMonitor.onMessageIngested(EventMessage<?> message)

Uses of EventMessage in org.axonframework.micrometer

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

Modifier and Type	Method and Description
MessageMonitor<? super EventMessage<?>>	GlobalMetricRegistry.registerEventBus(String eventBusName) Registers new metrics to the registry to monitor an EventBus.
MessageMonitor<? super EventMessage<?>>	GlobalMetricRegistry.registerEventBus(String eventBusName, Function<Message<?>,Iterable<io.micrometer.core.instrument.Tag>> tagsBuilder) Registers new metrics to the registry to monitor an EventBus using Tags through the given tagsBuilder.
MessageMonitor<? super EventMessage<?>>	GlobalMetricRegistry.registerEventProcessor(String eventProcessorName) Registers new metrics to the registry to monitor an EventProcessor.
MessageMonitor<? super EventMessage<?>>	GlobalMetricRegistry.registerEventProcessor(String eventProcessorName, Function<Message<?>,Iterable<io.micrometer.core.instrument.Tag>> tagsBuilder) Registers new metrics to the registry to monitor an EventProcessor using Tags through the given tagsBuilder.

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

Modifier and Type	Method and Description
MessageMonitor.MonitorCallback	EventProcessorLatencyMonitor.onMessageIngested(EventMessage<?> message)

Uses of EventMessage in org.axonframework.modelling.command.inspection

Methods in org.axonframework.modelling.command.inspection that return EventMessage

Modifier and Type	Method and Description
protected <P> EventMessage<P>	AnnotatedAggregate.createMessage(P payload, MetaData metaData) Creates an EventMessage with given payload and metaData.

Methods in org.axonframework.modelling.command.inspection with parameters of type EventMessage

Modifier and Type	Method and Description
protected void	AnnotatedAggregate.publish(EventMessage<?> msg) Publish an event to the aggregate root and its entities first and external event handlers (using the given event bus) later.
void	AnnotatedChildEntity.publish(EventMessage<?> msg, P declaringInstance)
void	ChildEntity.publish(EventMessage<?> msg, T declaringInstance) Publish the given msg to the appropriate handlers on the given declaringInstance
void	EntityModel.publish(EventMessage<?> message, T target) Publish given event message on the given target entity.
protected void	AnnotatedAggregate.publishOnEventBus(EventMessage<?> msg) Publish an event to external event handlers using the given event bus.
protected abstract <T> Stream<Object>	AbstractChildEntityDefinition.resolveEventTargets(EventMessage message, T parentEntity, Member member, ForwardingMode eventForwardingMode) Resolve the targets of an incoming EventMessage to the right Child Entities.
protected <T> Stream<Object>	AggregateMemberAnnotatedChildEntityDefinition.resolveEventTargets(EventMessage message, T parentEntity, Member member, ForwardingMode eventForwardingMode)
protected <T> Stream<Object>	AggregateMemberAnnotatedChildEntityCollectionDefinition.resolveEventTargets(EventMessage message, T parentEntity, Member member, ForwardingMode eventForwardingMode)
protected <T> Stream<Object>	AggregateMemberAnnotatedChildEntityMapDefinition.resolveEventTargets(EventMessage message, T parentEntity, Member member, ForwardingMode eventForwardingMode)

Constructor parameters in org.axonframework.modelling.command.inspection with type arguments of type EventMessage

Constructor and Description
AnnotatedChildEntity(EntityModel<C> entityModel, boolean forwardCommands, BiFunction<CommandMessage<?>,P,C> commandTargetResolver, BiFunction<EventMessage<?>,P,Stream<C>> eventTargetResolver) Initiates a new AnnotatedChildEntity instance that uses the provided entityModel to delegate command and event handling to an annotated child entity.

Uses of EventMessage in org.axonframework.modelling.saga

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

Modifier and Type	Method and Description
boolean	AnnotatedSaga.canHandle(EventMessage<?> event)
boolean	AnnotatedSagaManager.canHandle(EventMessage<?> eventMessage, Segment segment)
protected Set<AssociationValue>	AnnotatedSagaManager.extractAssociationValues(EventMessage<?> event)
protected abstract Set<AssociationValue>	AbstractSagaManager.extractAssociationValues(EventMessage<?> event) Extracts the AssociationValues from the given event as relevant for a Saga of given sagaType.
AssociationValue	SagaMethodMessageHandlingMember.getAssociationValue(EventMessage<?> eventMessage) The AssociationValue to find the saga instance with, or null if no AssociationValue can be found on the given eventMessage.
protected SagaInitializationPolicy	AnnotatedSagaManager.getSagaCreationPolicy(EventMessage<?> event)
protected abstract SagaInitializationPolicy	AbstractSagaManager.getSagaCreationPolicy(EventMessage<?> event) Returns the Saga Initialization Policy for a Saga of the given sagaType and event.
Object	AnnotatedSaga.handle(EventMessage<?> event)
void	AbstractSagaManager.handle(EventMessage<?> event, Segment segment)
<T> Object	MetaDataAssociationResolver.resolve(String associationPropertyName, EventMessage<?> message, MessageHandlingMember<T> handler) Finds the association property value by looking up the association property name in the event message's MetaData.
<T> Object	AssociationResolver.resolve(String associationPropertyName, EventMessage<?> message, MessageHandlingMember<T> handler) Resolves the associationPropertyName as a value.
<T> Object	PayloadAssociationResolver.resolve(String associationPropertyName, EventMessage<?> message, MessageHandlingMember<T> handler) Finds the association property value in the message's payload.

Uses of EventMessage in org.axonframework.modelling.saga.metamodel

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

Modifier and Type	Method and Description
List<MessageHandlingMember<? super T>>	SagaModel.findHandlerMethods(EventMessage<?> event) Returns a List of MessageHandlingMember that can handle the given event.
default boolean	SagaModel.hasHandlerMethod(EventMessage<?> eventMessage) Indicates whether the Saga described by this model has a handler for the given eventMessage
Optional<AssociationValue>	SagaModel.resolveAssociation(EventMessage<?> eventMessage) Returns the AssociationValue used to find sagas of type T that can handle the given eventMessage.

Uses of EventMessage in org.axonframework.spring.messaging

Methods in org.axonframework.spring.messaging that return EventMessage

Modifier and Type	Method and Description
<T> EventMessage<T>	EventMessageConverter.convertFromInboundMessage(org.springframework.messaging.Message<T> message) Converts a Spring inbound message into an Axon event Message
<T> EventMessage<T>	DefaultEventMessageConverter.convertFromInboundMessage(org.springframework.messaging.Message<T> message)
protected EventMessage<?>	InboundEventMessageChannelAdapter.transformMessage(org.springframework.messaging.Message<?> message) Transforms the given incoming Spring Messaging message to an Axon EventMessage.

Methods in org.axonframework.spring.messaging with parameters of type EventMessage

Modifier and Type	Method and Description
protected org.springframework.context.ApplicationEvent	ApplicationContextEventPublisher.convert(EventMessage<?> eventMessage) Converts the given Axon eventMessage to a Spring ApplicationEvent.
<T> org.springframework.messaging.Message<T>	EventMessageConverter.convertToOutboundMessage(EventMessage<T> event) Converts Axon event into Spring message.
<T> org.springframework.messaging.Message<T>	DefaultEventMessageConverter.convertToOutboundMessage(EventMessage<T> event)
protected org.springframework.messaging.Message<?>	OutboundEventMessageChannelAdapter.transform(EventMessage<?> event) Transforms the given Axon event into a Spring Messaging Message.

Method parameters in org.axonframework.spring.messaging with type arguments of type EventMessage

Modifier and Type	Method and Description
protected void	OutboundEventMessageChannelAdapter.handle(List<? extends EventMessage<?>> events) If allows by the filter, wraps the given event in a GenericMessage ands sends it to the configured MessageChannel.
Registration	InboundEventMessageChannelAdapter.subscribe(Consumer<List<? extends EventMessage<?>>> messageProcessor)

Constructor parameters in org.axonframework.spring.messaging with type arguments of type EventMessage

Constructor and Description
ApplicationContextEventPublisher(SubscribableMessageSource<? extends EventMessage<?>> messageSource) Initialize the publisher to forward events received from the given messageSource to the application context that this bean is part of.
InboundEventMessageChannelAdapter(List<Consumer<List<? extends EventMessage<?>>>> processors, EventMessageConverter eventMessageConverter) Initialize the adapter to publish all incoming events to the subscribed processors.
OutboundEventMessageChannelAdapter(SubscribableMessageSource<EventMessage<?>> messageSource, org.springframework.messaging.MessageChannel channel) Initialize an adapter to forward messages from the given messageSource to the given channel.
OutboundEventMessageChannelAdapter(SubscribableMessageSource<EventMessage<?>> messageSource, org.springframework.messaging.MessageChannel channel, Predicate<? super EventMessage<?>> filter) Initialize an adapter to forward messages from the given messageSource to the given channel.
OutboundEventMessageChannelAdapter(SubscribableMessageSource<EventMessage<?>> messageSource, org.springframework.messaging.MessageChannel channel, Predicate<? super EventMessage<?>> filter) Initialize an adapter to forward messages from the given messageSource to the given channel.
OutboundEventMessageChannelAdapter(SubscribableMessageSource<EventMessage<?>> messageSource, org.springframework.messaging.MessageChannel channel, Predicate<? super EventMessage<?>> filter, EventMessageConverter eventMessageConverter) Initialize an adapter to forward messages from the given messageSource to the given channel.
OutboundEventMessageChannelAdapter(SubscribableMessageSource<EventMessage<?>> messageSource, org.springframework.messaging.MessageChannel channel, Predicate<? super EventMessage<?>> filter, EventMessageConverter eventMessageConverter) Initialize an adapter to forward messages from the given messageSource to the given channel.

Uses of EventMessage in org.axonframework.test.aggregate

Methods in org.axonframework.test.aggregate that return types with arguments of type EventMessage

Modifier and Type	Method and Description
List<EventMessage<?>>	StubAggregateLifecycle.getAppliedEvents() Returns the list of applied Events for this lifecycle instance.

Methods in org.axonframework.test.aggregate with parameters of type EventMessage

Modifier and Type	Method and Description
ResultValidator<T>	ResultValidator.expectEvents(EventMessage<?>... expectedEvents) Expect the given set of events to have been published.
ResultValidator<T>	ResultValidatorImpl.expectEvents(EventMessage<?>... expectedEvents)

Method parameters in org.axonframework.test.aggregate with type arguments of type EventMessage

Modifier and Type	Method and Description
ResultValidator<T>	ResultValidator.expectEventsMatching(org.hamcrest.Matcher<? extends List<? super EventMessage<?>>> matcher) Expect the published events to match the given matcher.
ResultValidator<T>	ResultValidatorImpl.expectEventsMatching(org.hamcrest.Matcher<? extends List<? super EventMessage<?>>> matcher)

Constructor parameters in org.axonframework.test.aggregate with type arguments of type EventMessage

Constructor and Description
ResultValidatorImpl(List<EventMessage<?>> publishedEvents, FieldFilter fieldFilter, Supplier<Aggregate<T>> aggregateState, StubDeadlineManager stubDeadlineManager) Initialize the ResultValidatorImpl with the given storedEvents and publishedEvents.

Uses of EventMessage in org.axonframework.test.eventscheduler

Methods in org.axonframework.test.eventscheduler that return EventMessage

Modifier and Type	Method and Description
EventMessage	StubEventScheduler.advanceToNextTrigger() Advances the "current time" of the scheduler to the next scheduled Event, and returns that event.
EventMessage	StubScheduleToken.getEvent()
EventMessage	ScheduledItem.getEvent() The Event scheduled for publication.

Method parameters in org.axonframework.test.eventscheduler with type arguments of type EventMessage

Modifier and Type	Method and Description
void	StubEventScheduler.advanceTimeBy(Duration duration, EventConsumer<EventMessage<?>> eventConsumer) Advance time by the given duration and invokes the given eventConsumer for each event scheduled for publication until that time.
void	StubEventScheduler.advanceTimeTo(Instant newDateTime, EventConsumer<EventMessage<?>> eventConsumer) Advance time to the given newDateTime and invokes the given eventConsumer for each event scheduled for publication until that time.

Uses of EventMessage in org.axonframework.test.matchers

Methods in org.axonframework.test.matchers that return types with arguments of type EventMessage

Modifier and Type	Method and Description
static org.hamcrest.Matcher<List<EventMessage<?>>>	Matchers.noEvents() Matches an empty List of Events.

Uses of EventMessage in org.axonframework.test.saga

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

Modifier and Type	Method and Description
Object	EventValidator.handle(EventMessage event)
protected void	SagaTestFixture.handleInSaga(EventMessage<?> event) Handles the given event in the scope of a Unit of Work.

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

Modifier and Type	Method and Description
FixtureExecutionResult	FixtureExecutionResult.expectNoScheduledEventMatching(Duration durationToScheduledTime, org.hamcrest.Matcher<? super EventMessage<?>> matcher) Asserts that no event matching the given matcher has been scheduled to be published after the given durationToScheduledTime.
FixtureExecutionResult	FixtureExecutionResultImpl.expectNoScheduledEventMatching(Duration durationToScheduledTime, org.hamcrest.Matcher<? super EventMessage<?>> matcher)
FixtureExecutionResult	FixtureExecutionResult.expectNoScheduledEventMatching(Instant scheduledTime, org.hamcrest.Matcher<? super EventMessage<?>> matcher) Asserts that no event matching the given matcher has been scheduled at the given scheduledTime.
FixtureExecutionResult	FixtureExecutionResultImpl.expectNoScheduledEventMatching(Instant scheduledTime, org.hamcrest.Matcher<? super EventMessage<?>> matcher)
FixtureExecutionResult	FixtureExecutionResult.expectPublishedEventsMatching(org.hamcrest.Matcher<? extends List<? super EventMessage<?>>> matcher) Assert that the saga published events on the EventBus as defined by the given matcher.
FixtureExecutionResult	FixtureExecutionResultImpl.expectPublishedEventsMatching(org.hamcrest.Matcher<? extends List<? super EventMessage<?>>> matcher)
FixtureExecutionResult	FixtureExecutionResult.expectScheduledEventMatching(Duration duration, org.hamcrest.Matcher<? super EventMessage<?>> matcher) Asserts that an event matching the given matcher has been scheduled to be published after the given duration.
FixtureExecutionResult	FixtureExecutionResultImpl.expectScheduledEventMatching(Duration duration, org.hamcrest.Matcher<? super EventMessage<?>> matcher)
FixtureExecutionResult	FixtureExecutionResult.expectScheduledEventMatching(Instant scheduledTime, org.hamcrest.Matcher<? super EventMessage<?>> matcher) Asserts that an event matching the given matcher has been scheduled to be published at the given scheduledTime.
FixtureExecutionResult	FixtureExecutionResultImpl.expectScheduledEventMatching(Instant scheduledTime, org.hamcrest.Matcher<? super EventMessage<?>> matcher)