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.deadletter
org.axonframework.eventhandling.deadletter.jdbc
org.axonframework.eventhandling.deadletter.jpa
org.axonframework.eventhandling.deadletter.legacyjpa
org.axonframework.eventhandling.gateway
org.axonframework.eventhandling.interceptors
org.axonframework.eventhandling.pooled
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.eventsourcing.eventstore.legacyjpa
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.springboot.util
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

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

Modifier and Type	Method and Description
SequencingPolicy<EventMessage<?>>	PersistentStreamSequencingPolicyProvider.apply(Configuration configuration)
SubscribableMessageSource<EventMessage<?>>	PersistentStreamMessageSourceDefinition.create(Configuration configuration)

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

Modifier and Type	Method and Description
AxonServerEventStoreFactory.Builder	AxonServerEventStoreFactory.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor) Sets the MessageMonitor to monitor ingested EventMessages.
AxonServerEventStore.Builder	AxonServerEventStore.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor)
void	PersistentStreamConnection.open(Consumer<List<? extends EventMessage<?>>> consumer) Initiates the connection to Axon Server to read events from the persistent stream.
Registration	PersistentStreamMessageSource.subscribe(Consumer<List<? extends EventMessage<?>>> consumer)

Uses of EventMessage in org.axonframework.config

Fields in org.axonframework.config with type parameters of type EventMessage

Modifier and Type	Field and Description
protected Map<String,Component<EnqueuePolicy<EventMessage<?>>>>	EventProcessingModule.deadLetterPolicies
protected Function<String,Function<Configuration,SequencedDeadLetterQueue<EventMessage<?>>>>	EventProcessingModule.deadLetterQueueProvider
protected Map<String,Component<SequencedDeadLetterQueue<EventMessage<?>>>>	EventProcessingModule.deadLetterQueues
protected List<BiFunction<Configuration,String,MessageHandlerInterceptor<? super EventMessage<?>>>>	EventProcessingModule.defaultHandlerInterceptors
protected Map<String,List<Function<Configuration,MessageHandlerInterceptor<? super EventMessage<?>>>>>	EventProcessingModule.handlerInterceptorsBuilders
protected Map<String,Component<SequencingPolicy<? super EventMessage<?>>>>	EventProcessingModule.sequencingPolicies

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

Modifier and Type	Method and Description
Optional<EnqueuePolicy<EventMessage<?>>>	EventProcessingModule.deadLetterPolicy(String processingGroup)
default Optional<EnqueuePolicy<EventMessage<?>>>	EventProcessingConfiguration.deadLetterPolicy(String processingGroup) Returns the dead letter policy tied to the given processingGroup in an Optional.
Optional<SequencedDeadLetterQueue<EventMessage<?>>>	EventProcessingModule.deadLetterQueue(String processingGroup)
default Optional<SequencedDeadLetterQueue<EventMessage<?>>>	EventProcessingConfiguration.deadLetterQueue(String processingGroup) Returns the SequencedDeadLetterQueue tied to the given processingGroup in an Optional.
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.
Optional<SequencedDeadLetterProcessor<EventMessage<?>>>	EventProcessingModule.sequencedDeadLetterProcessor(String processingGroup)
default Optional<SequencedDeadLetterProcessor<EventMessage<?>>>	EventProcessingConfiguration.sequencedDeadLetterProcessor(String processingGroup) Returns the SequencedDeadLetterProcessor tied to the given processingGroup in an Optional.
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.registerDeadLetterPolicy(String processingGroup, Function<Configuration,EnqueuePolicy<EventMessage<?>>> policyBuilder)
default EventProcessingConfigurer	EventProcessingConfigurer.registerDeadLetterPolicy(String processingGroup, Function<Configuration,EnqueuePolicy<EventMessage<?>>> policyBuilder) Register a dead letter policy for the given processingGroup using a dead letter queue.
EventProcessingConfigurer	EventProcessingModule.registerDeadLetterQueue(String processingGroup, Function<Configuration,SequencedDeadLetterQueue<EventMessage<?>>> queueBuilder)
default EventProcessingConfigurer	EventProcessingConfigurer.registerDeadLetterQueue(String processingGroup, Function<Configuration,SequencedDeadLetterQueue<EventMessage<?>>> queueBuilder) Register a SequencedDeadLetterQueue for the given processingGroup.
EventProcessingConfigurer	EventProcessingModule.registerDeadLetterQueueProvider(Function<String,Function<Configuration,SequencedDeadLetterQueue<EventMessage<?>>>> deadLetterQueueProvider)
default EventProcessingConfigurer	EventProcessingConfigurer.registerDeadLetterQueueProvider(Function<String,Function<Configuration,SequencedDeadLetterQueue<EventMessage<?>>>> deadLetterQueueProvider) Register the given deadLetterProvider as a default to build a SequencedDeadLetterQueue for EventProcessors created in this configuration.
EventProcessingConfigurer	EventProcessingModule.registerDefaultDeadLetterPolicy(Function<Configuration,EnqueuePolicy<EventMessage<?>>> policyBuilder)
default EventProcessingConfigurer	EventProcessingConfigurer.registerDefaultDeadLetterPolicy(Function<Configuration,EnqueuePolicy<EventMessage<?>>> policyBuilder) Register a default dead letter policy for any processing group using a dead letter queue.
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.
protected EventProcessor	EventProcessingModule.subscribingEventProcessor(String name, EventHandlerInvoker eventHandlerInvoker, SubscribableMessageSource<? extends EventMessage<?>> messageSource) Default SubscribingEventProcessor configuration based on this configure module.

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.
<T> EventMessage<T>	EventBusSpanFactory.propagateContext(EventMessage<T> eventMessage) Propagates the context of the current span to the given event message.
<T> EventMessage<T>	DefaultEventBusSpanFactory.propagateContext(EventMessage<T> 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<?>>>	EventProcessor.getHandlerInterceptors() Return the list of already registered MessageHandlerInterceptors for this event processor.
List<MessageHandlerInterceptor<? super EventMessage<?>>>	AbstractEventProcessor.getHandlerInterceptors()
SubscribableMessageSource<? extends EventMessage<?>>	SubscribingEventProcessor.getMessageSource() Returns the message source from which this processor receives its events
SequencingPolicy<? super EventMessage<?>>	SimpleEventHandlerInvoker.getSequencingPolicy() Return the SequencingPolicy as configured for this EventHandlerInvoker.
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) 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.
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)
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.
protected boolean	AbstractEventProcessor.canHandle(EventMessage<?> eventMessage, Segment segment) Indicates whether the processor can/should handle the given eventMessage for the given segment.
Span	EventProcessorSpanFactory.createProcessEventSpan(boolean streaming, EventMessage<?> eventMessage) Creates a span for the handling of an event.
Span	DefaultEventProcessorSpanFactory.createProcessEventSpan(boolean streaming, EventMessage<?> eventMessage)
Span	EventBusSpanFactory.createPublishEventSpan(EventMessage<?> eventMessage) Creates a span for the publishing of an event.
Span	DefaultEventBusSpanFactory.createPublishEventSpan(EventMessage<?> eventMessage)
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.
protected void	SimpleEventHandlerInvoker.invokeHandlers(EventMessage<?> message)
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.
<T> EventMessage<T>	EventBusSpanFactory.propagateContext(EventMessage<T> eventMessage) Propagates the context of the current span to the given event message.
<T> EventMessage<T>	DefaultEventBusSpanFactory.propagateContext(EventMessage<T> eventMessage)
default void	EventBus.publish(EventMessage<?>... events) Publish a collection of events on this bus (one, or multiple).
static <T> Optional<T>	ReplayToken.replayContext(EventMessage<?> message, Class<T> contextClass) Extracts the context from a message of the matching contextClass.
protected void	AbstractEventProcessor.reportIgnored(EventMessage<?> eventMessage) Report the given eventMessage as ignored.
protected Object	SimpleEventHandlerInvoker.sequenceIdentifier(EventMessage<?> event)
protected boolean	SimpleEventHandlerInvoker.sequencingPolicyMatchesSegment(EventMessage<?> message, Segment segment)

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.
Span	EventProcessorSpanFactory.createBatchSpan(boolean streaming, List<? extends EventMessage<?>> eventMessages) Creates a span for the batch of events that are handled by the event processor.
Span	DefaultEventProcessorSpanFactory.createBatchSpan(boolean streaming, List<? extends EventMessage<?>> eventMessages)
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.
TrackingEventProcessor.Builder	TrackingEventProcessor.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor)
SubscribingEventProcessor.Builder	SubscribingEventProcessor.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor)
SimpleEventBus.Builder	SimpleEventBus.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.
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	AbstractEventBus.registerDispatchInterceptor(MessageDispatchInterceptor<? super EventMessage<?>> dispatchInterceptor) Register the given DispatchInterceptor.
Registration	AbstractEventProcessor.registerHandlerInterceptor(MessageHandlerInterceptor<? super EventMessage<?>> interceptor)
B	SimpleEventHandlerInvoker.Builder.sequencingPolicy(SequencingPolicy<? super EventMessage<?>> sequencingPolicy) Sets the SequencingPolicy in charge of deciding whether a given event should be handled (through EventHandlerInvoker.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	PropertySequencingPolicy.getSequenceIdentifierFor(EventMessage eventMessage)
Object	FullConcurrencyPolicy.getSequenceIdentifierFor(EventMessage<?> event)

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

Modifier and Type	Method and Description
PropertySequencingPolicy.Builder<T,K>	PropertySequencingPolicy.Builder.fallbackSequencingPolicy(SequencingPolicy<EventMessage> fallbackSequencingPolicy) Defines the fallback sequencing policy, the sequencing policy which is applied if the event message payload is not of a supported type.
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.deadletter

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

Modifier and Type	Method and Description
void	DeadLetteringEventHandlerInvoker.handle(EventMessage<?> message, Segment segment)

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

Modifier and Type	Method and Description
DeadLetteringEventHandlerInvoker.Builder	DeadLetteringEventHandlerInvoker.Builder.enqueuePolicy(EnqueuePolicy<EventMessage<?>> enqueuePolicy) Sets the EnqueuePolicy this EventHandlerInvoker uses to decide whether a dead letter should be added to the SequencedDeadLetterQueue.
boolean	DeadLetteringEventHandlerInvoker.process(Predicate<DeadLetter<? extends EventMessage<?>>> sequenceFilter)
DeadLetteringEventHandlerInvoker.Builder	DeadLetteringEventHandlerInvoker.Builder.queue(SequencedDeadLetterQueue<EventMessage<?>> queue) Sets the SequencedDeadLetterQueue this EventHandlerInvoker maintains dead letters with.
Registration	DeadLetteringEventHandlerInvoker.registerHandlerInterceptor(MessageHandlerInterceptor<? super EventMessage<?>> interceptor)

Uses of EventMessage in org.axonframework.eventhandling.deadletter.jdbc

Classes in org.axonframework.eventhandling.deadletter.jdbc with type parameters of type EventMessage

Modifier and Type	Interface and Description
interface	DeadLetterJdbcConverter<E extends EventMessage<?>,D extends JdbcDeadLetter<E>> A functional interface describing how to convert a ResultSet in JdbcDeadLetter implementation of type D
interface	DeadLetterStatementFactory<E extends EventMessage<?>> A contract towards all PreparedStatements a JdbcSequencedDeadLetterQueue requires to function.
class	DefaultDeadLetterJdbcConverter<E extends EventMessage<?>> Default implementation of the DeadLetterJdbcConverter, converting ResultSets into JdbcDeadLetter instances.
protected static class	DefaultDeadLetterJdbcConverter.Builder<E extends EventMessage<?>> Builder class to instantiate a DefaultDeadLetterJdbcConverter.
class	DefaultDeadLetterStatementFactory<E extends EventMessage<?>> Default implementation of the DeadLetterStatementFactory used by the JdbcSequencedDeadLetterQueue Constructs PreparedStatements that are compatible with most databases.
protected static class	DefaultDeadLetterStatementFactory.Builder<E extends EventMessage<?>> Builder class to instantiate a DefaultDeadLetterStatementFactory.
class	JdbcDeadLetter<E extends EventMessage<?>> A DeadLetter that was saved to a JDBC-backed database and reconstructed from it.
class	JdbcSequencedDeadLetterQueue<E extends EventMessage<?>> A JDBC-based implementation of the SequencedDeadLetterQueue, used for storing dead letters containing event messages durably.
static class	JdbcSequencedDeadLetterQueue.Builder<E extends EventMessage<?>> Builder class to instantiate an JdbcSequencedDeadLetterQueue.

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

Modifier and Type	Method and Description
static <E extends EventMessage<?>> JdbcSequencedDeadLetterQueue.Builder<E>	JdbcSequencedDeadLetterQueue.builder() Instantiate a builder to construct a JdbcSequencedDeadLetterQueue.
static <E extends EventMessage<?>> DefaultDeadLetterStatementFactory.Builder<E>	DefaultDeadLetterStatementFactory.builder() Instantiate a builder to construct a DefaultDeadLetterStatementFactory.
static <E extends EventMessage<?>> DefaultDeadLetterJdbcConverter.Builder<E>	DefaultDeadLetterJdbcConverter.builder() Instantiate a builder to construct a DefaultDeadLetterJdbcConverter.

Uses of EventMessage in org.axonframework.eventhandling.deadletter.jpa

Classes in org.axonframework.eventhandling.deadletter.jpa with type parameters of type EventMessage

Modifier and Type	Interface and Description
interface	DeadLetterJpaConverter<M extends EventMessage<?>> Converter that can convert a EventMessage to a DeadLetterEventEntry and vice versa.
class	JpaDeadLetter<M extends EventMessage<?>> A DeadLetter that was saved to the database and reconstructed from it.
class	JpaSequencedDeadLetterQueue<M extends EventMessage<?>> JPA-backed implementation of the SequencedDeadLetterQueue, used for storing dead letters containing Eventmessages durably as a DeadLetterEntry.
static class	JpaSequencedDeadLetterQueue.Builder<T extends EventMessage<?>> Builder class to instantiate an JpaSequencedDeadLetterQueue.

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

Modifier and Type	Method and Description
static <M extends EventMessage<?>> JpaSequencedDeadLetterQueue.Builder<M>	JpaSequencedDeadLetterQueue.builder() Creates a new builder, capable of building a JpaSequencedDeadLetterQueue according to the provided configuration.

Methods in org.axonframework.eventhandling.deadletter.jpa that return EventMessage

Modifier and Type	Method and Description
EventMessage<?>	EventMessageDeadLetterJpaConverter.convert(DeadLetterEventEntry entry, Serializer eventSerializer, Serializer genericSerializer)

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

Modifier and Type	Method and Description
boolean	EventMessageDeadLetterJpaConverter.canConvert(EventMessage<?> message)
DeadLetterEventEntry	EventMessageDeadLetterJpaConverter.convert(EventMessage<?> message, Serializer eventSerializer, Serializer genericSerializer)

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

Modifier and Type	Method and Description
JpaSequencedDeadLetterQueue.Builder<T>	JpaSequencedDeadLetterQueue.Builder.addConverter(DeadLetterJpaConverter<EventMessage<?>> converter) Adds a DeadLetterJpaConverter to the configuration, which is used to deserialize dead-letter entries from the database.

Uses of EventMessage in org.axonframework.eventhandling.deadletter.legacyjpa

Classes in org.axonframework.eventhandling.deadletter.legacyjpa with type parameters of type EventMessage

Modifier and Type	Interface and Description
interface	DeadLetterJpaConverter<M extends EventMessage<?>> Deprecated. in favor of using DeadLetterJpaConverter which moved to jakarta.
class	JpaDeadLetter<M extends EventMessage<?>> Deprecated. in favor of using JpaDeadLetter which moved to jakarta.
class	JpaSequencedDeadLetterQueue<M extends EventMessage<?>> Deprecated. in favor of using JpaSequencedDeadLetterQueue which moved to jakarta.
static class	JpaSequencedDeadLetterQueue.Builder<T extends EventMessage<?>> Deprecated. Builder class to instantiate an JpaSequencedDeadLetterQueue.

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

Modifier and Type	Method and Description
static <M extends EventMessage<?>> JpaSequencedDeadLetterQueue.Builder<M>	JpaSequencedDeadLetterQueue.builder() Deprecated. Creates a new builder, capable of building a JpaSequencedDeadLetterQueue according to the provided configuration.

Methods in org.axonframework.eventhandling.deadletter.legacyjpa that return EventMessage

Modifier and Type	Method and Description
EventMessage<?>	EventMessageDeadLetterJpaConverter.convert(DeadLetterEventEntry entry, Serializer eventSerializer, Serializer genericSerializer) Deprecated.

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

Modifier and Type	Method and Description
boolean	EventMessageDeadLetterJpaConverter.canConvert(EventMessage<?> message) Deprecated.
DeadLetterEventEntry	EventMessageDeadLetterJpaConverter.convert(EventMessage<?> message, Serializer eventSerializer, Serializer genericSerializer) Deprecated.

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

Modifier and Type	Method and Description
JpaSequencedDeadLetterQueue.Builder<T>	JpaSequencedDeadLetterQueue.Builder.addConverter(DeadLetterJpaConverter<EventMessage<?>> converter) Adds a DeadLetterJpaConverter to the configuration, which is used to deserialize dead-letter entries from the database.

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
DefaultEventGateway.Builder	DefaultEventGateway.Builder.dispatchInterceptors(List<MessageDispatchInterceptor<? super EventMessage<?>>> dispatchInterceptors)
AbstractEventGateway.Builder	AbstractEventGateway.Builder.dispatchInterceptors(List<MessageDispatchInterceptor<? super EventMessage<?>>> dispatchInterceptors) Sets the List of MessageDispatchInterceptors for EventMessages.
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.pooled

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

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

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.
void	AbstractSnapshotTrigger.eventHandled(EventMessage<?> msg)
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	SequenceEventStorageEngine.appendEvents(List<? extends EventMessage<?>> events)
void	EventStorageEngine.appendEvents(List<? extends EventMessage<?>> events) Append a list of events to the event storage.
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.
EmbeddedEventStore.Builder	EmbeddedEventStore.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor)
AbstractEventStore.Builder	AbstractEventStore.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

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

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

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 static <T> DomainEventMessage<T>	JpaEventStorageEngine.asDomainEventMessage(EventMessage<T> event) Converts an EventMessage to a DomainEventMessage.
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.eventsourcing.eventstore.legacyjpa

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

Modifier and Type	Method and Description
protected static <T> DomainEventMessage<T>	JpaEventStorageEngine.asDomainEventMessage(EventMessage<T> event) Deprecated. Converts an EventMessage to a DomainEventMessage.
protected Object	JpaEventStorageEngine.createEventEntity(EventMessage<?> eventMessage, Serializer serializer) Deprecated. Returns a Jpa event entity for given eventMessage.

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

Modifier and Type	Method and Description
protected void	EmbeddedEventStore.afterCommit(List<? extends EventMessage<?>> events) Deprecated.
protected void	JpaEventStorageEngine.appendEvents(List<? extends EventMessage<?>> events, Serializer serializer) Deprecated.
EmbeddedEventStore.Builder	EmbeddedEventStore.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor)

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) Deprecated. Please use the GlobalMetricRegistry.registerEventProcessor(String, Function, Function) instead, which has separate tags for the latency metric.
MessageMonitor<? super EventMessage<?>>	GlobalMetricRegistry.registerEventProcessor(String eventProcessorName, Function<Message<?>,Iterable<io.micrometer.core.instrument.Tag>> tagsBuilder, Function<Message<?>,Iterable<io.micrometer.core.instrument.Tag>> latencyTagsBuilder) 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	EntityModel.publish(EventMessage<?> message, T target) Publish given event message on the given target entity.
void	ChildEntity.publish(EventMessage<?> msg, T declaringInstance) Publish the given msg to the appropriate handlers on the given declaringInstance.
protected void	AnnotatedAggregate.publishOnEventBus(EventMessage<?> msg) Publish an event to external event handlers using the given event bus.
protected <T> Stream<Object>	AggregateMemberAnnotatedChildEntityMapDefinition.resolveEventTargets(EventMessage message, T parentEntity, Member member, ForwardingMode eventForwardingMode)
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 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.

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)
Span	SagaManagerSpanFactory.createCreateSagaInstanceSpan(EventMessage<?> event, Class<?> sagaType, String sagaIdentifier) Creates a span that represents the creation of a new saga instance.
Span	DefaultSagaManagerSpanFactory.createCreateSagaInstanceSpan(EventMessage<?> event, Class<?> sagaType, String sagaIdentifier)
Span	SagaManagerSpanFactory.createInvokeSagaSpan(EventMessage<?> event, Class<?> sagaType, Saga<?> saga) Creates a span that represents the invocation of a saga.
Span	DefaultSagaManagerSpanFactory.createInvokeSagaSpan(EventMessage<?> event, Class<?> sagaType, Saga<?> saga)
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	PayloadAssociationResolver.resolve(String associationPropertyName, EventMessage<?> message, MessageHandlingMember<T> handler) Finds the association property value in the message's payload.
<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.

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

Constructor parameters in org.axonframework.springboot.util with type arguments of type EventMessage

Constructor and Description

DeadLetterQueueProviderConfigurerModule(EventProcessorProperties eventProcessorProperties, Function<String,Function<Configuration,SequencedDeadLetterQueue<EventMessage<?>>>> deadLetterQueueProvider) Construct a DeadLetterQueueProviderConfigurerModule, using the given eventProcessorProperties to decide which processing groups receive the SequencedDeadLetterQueue from the given deadLetterQueueProvider.

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>	ResultValidatorImpl.expectEvents(EventMessage<?>... expectedEvents)
ResultValidator<T>	ResultValidator.expectEvents(EventMessage<?>... expectedEvents) Expect the given set of events to have been published.

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

Modifier and Type	Method and Description
ResultValidator<T>	ResultValidatorImpl.expectEventsMatching(org.hamcrest.Matcher<? extends List<? super EventMessage<?>>> matcher)
ResultValidator<T>	ResultValidator.expectEventsMatching(org.hamcrest.Matcher<? extends List<? super EventMessage<?>>> matcher) Expect the published events to match the given 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.
void	RecordingListenerInvocationErrorHandler.onError(Exception exception, EventMessage<?> event, EventMessageHandler eventHandler)

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

Modifier and Type	Method and Description
FixtureExecutionResult	FixtureExecutionResultImpl.expectNoScheduledEventMatching(Duration durationToScheduledTime, org.hamcrest.Matcher<? super EventMessage<?>> matcher)
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(Instant scheduledTime, 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.expectPublishedEventsMatching(org.hamcrest.Matcher<? extends List<? 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.expectScheduledEventMatching(Duration duration, org.hamcrest.Matcher<? 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(Instant scheduledTime, 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.
FixtureConfiguration	SagaTestFixture.registerEventHandlerInterceptor(MessageHandlerInterceptor<? super EventMessage<?>> eventHandlerInterceptor)
default FixtureConfiguration	FixtureConfiguration.registerEventHandlerInterceptor(MessageHandlerInterceptor<? super EventMessage<?>> eventHandlerInterceptor) Registers a MessageHandlerInterceptor for EventMessages.