Uses of Interface
org.axonframework.messaging.eventhandling.EventMessage

Packages that use EventMessage

Package	Description
io.axoniq.framework.axonserver.connector.event	Part of the Axon Server Connector module.
io.axoniq.framework.messaging.eventhandling.deadletter	Part of the Axon Messaging module.
io.axoniq.framework.messaging.eventhandling.deadletter.jdbc	Part of the Axon Messaging module.
io.axoniq.framework.messaging.eventhandling.deadletter.jpa	Part of the Axon Messaging module.
io.axoniq.framework.messaging.eventstreaming	Part of the Axoniq Messaging folder.
io.axoniq.framework.messaging.multitenancy.axonserver.eventstreaming	Axon Server specific multi-tenant event streaming infrastructure, giving each tenant its own persistent stream and labelling the events it delivers with the tenant they belong to.
io.axoniq.framework.messaging.multitenancy.deadletter	Integrates dead-letter queue handling with multi-tenant event processing.
io.axoniq.framework.messaging.multitenancy.eventsourcing	Package containing multitenancy support for event sourcing components.
io.axoniq.framework.messaging.transformation.events	Part of the Axoniq Messaging folder.
io.axoniq.framework.postgresql	Postgres extension main package.
io.axoniq.framework.workflow.dsl.api	Author-facing DSL entry points, step-definition value types, event conditions, and workflow lifecycle exceptions.
io.axoniq.framework.workflow.dsl.base	Base Java DSL for defining workflow steps, providing the core primitives to execute work, wait for events, modify the workflow payload, sleep, fail, and cancel a workflow.
io.axoniq.framework.workflow.dsl.simple	Convenience Java DSL built on top of the base DSL, adding shortcuts for common workflow steps such as executing without extra input payload, waiting for a typed event, and replacing the workflow payload outright.
io.axoniq.framework.workflow.history.inmemory	In-memory WorkflowHistoryRepository implementation and the event handler that projects workflow events into it.
io.axoniq.framework.workflow.runtime.api.execution.context	Internal runtime contracts for workflow execution, command dispatch, configuration, and event publication.
io.axoniq.framework.workflow.runtime.association	The association DSL used to correlate incoming events with waiting workflow steps, including value retrievers, comparison operators, and their serialized representation.
io.axoniq.framework.workflow.runtime.execution	Internal implementation of the workflow execution engine: the WorkflowEngine, its scheduling, state and storage, checkpointing/replay support, cancellation coordination, and the delegates implementing individual step primitives.
io.axoniq.framework.workflow.runtime.util	Internal runtime utilities for future resolution, workflow event and metadata construction, processing context propagation, reflection, and workflow state inspection.
org.axonframework.deadline	Deadline support carried over from Axon Framework 4, to keep deadlines that were scheduled before migrating firing while a project moves off this API.
org.axonframework.eventsourcing	Root package for Axon Eventsourcing.
org.axonframework.eventsourcing.annotation.reflection	Part of the Axon Eventsourcing module.
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	Part of the Axon Eventsourcing module.
org.axonframework.eventsourcing.eventstore.jpa	Part of the Axon Eventsourcing module.
org.axonframework.eventsourcing.eventstore.tracing	Event-store tracing decorators and event-sourcing-specific SpanAttributesProvider implementations.
org.axonframework.eventsourcing.handler	Package for the sourcing handler API.
org.axonframework.eventsourcing.snapshot.api	Public API for snapshotting of event-sourced entities.
org.axonframework.extension.metrics.dropwizard	Part of the Axon Extension module.
org.axonframework.extension.metrics.micrometer	Part of the Axon Extension module.
org.axonframework.extension.reactor.messaging.core.interception	Part of the Axon Extension module.
org.axonframework.extension.reactor.messaging.eventhandling.gateway	Part of the Axon Extension module.
org.axonframework.extension.spring.messaging	Part of the Axon Extension module.
org.axonframework.messaging.core	Classes related to message processing in Axon Framework.
org.axonframework.messaging.core.configuration	Part of the Axon Messaging module.
org.axonframework.messaging.core.interception	Part of the Axon Messaging module.
org.axonframework.messaging.core.sequencing	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling	Package for event handling components in Axon Framework.
org.axonframework.messaging.eventhandling.annotation	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.configuration	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.conversion	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.interception	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.processing	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.processing.errorhandling	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.processing.streaming.pooled	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.processing.streaming.segmenting	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.processing.subscribing	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.replay	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.tracing	Tracing decorators for event handling components.
org.axonframework.messaging.eventstreaming	Part of the Axon Messaging module.
org.axonframework.messaging.monitoring.configuration	Part of the Axon Messaging module.
org.axonframework.messaging.monitoring.interception	Part of the Axon Messaging module.
org.axonframework.modelling	Root package for Axon Modelling.
org.axonframework.modelling.annotation	Part of the Axon Modelling module.
org.axonframework.modelling.entity	Part of the Axon Modelling module.
org.axonframework.modelling.entity.annotation	Part of the Axon Modelling module.
org.axonframework.modelling.entity.child	Part of the Axon Modelling module.
org.axonframework.modelling.saga	Association values, the means by which an event is correlated to the saga instances that should handle it.
org.axonframework.modelling.saga.metamodel	Meta-model support for describing the structure and event handling capabilities of Axon Framework 4 style annotated Sagas.
org.axonframework.test.fixture	Part of the Axon Test module.
org.axonframework.test.matchers	Part of the Axon Test module.
org.axonframework.test.saga	Test support for the sagas carried by axon-legacy.

Uses of EventMessage in io.axoniq.framework.axonserver.connector.event

Methods in io.axoniq.framework.axonserver.connector.event that return EventMessage

Modifier and Type	Method	Description
EventMessage	TaggedEventConverter.convertEvent(io.axoniq.axonserver.grpc.event.dcb.Event event)	Convert the given event to an EventMessage.

Methods in io.axoniq.framework.axonserver.connector.event that return types with arguments of type EventMessage

Modifier and Type	Method	Description
Optional<MessageStream.Entry<EventMessage>>	SourcingEventMessageStream.next()
Optional<MessageStream.Entry<EventMessage>>	StreamingEventMessageStream.next()
Optional<MessageStream.Entry<EventMessage>>	SourcingEventMessageStream.peek()
Optional<MessageStream.Entry<EventMessage>>	StreamingEventMessageStream.peek()
MessageStream<EventMessage>	AggregateBasedAxonServerEventStorageEngine.source(SourcingCondition condition, @Nullable ProcessingContext context)
MessageStream<EventMessage>	AxonServerEventStorageEngine.source(SourcingCondition condition, @Nullable ProcessingContext context)
MessageStream<EventMessage>	AggregateBasedAxonServerEventStorageEngine.stream(StreamingCondition condition)
MessageStream<EventMessage>	AxonServerEventStorageEngine.stream(StreamingCondition condition)

Method parameters in io.axoniq.framework.axonserver.connector.event with type arguments of type EventMessage

Modifier and Type	Method	Description
void	PersistentStreamConnection.open(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> consumer)	Initiates the connection to Axon Server and starts delivering events to the given consumer.
Registration	PersistentStreamEventSource.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)

Uses of EventMessage in io.axoniq.framework.messaging.eventhandling.deadletter

Fields in io.axoniq.framework.messaging.eventhandling.deadletter with type parameters of type EventMessage

Modifier and Type	Field	Description
static final EnqueuePolicy<EventMessage>	DeadLetterQueueConfiguration.DEFAULT_ENQUEUE_POLICY	The default enqueue policy that always enqueues with a truncated cause message.

Methods in io.axoniq.framework.messaging.eventhandling.deadletter that return types with arguments of type EventMessage

Modifier and Type	Method	Description
SequencedDeadLetterQueue<EventMessage>	SequencedDeadLetterQueueFactory.create(String processingGroup, Configuration configuration)	Creates a SequencedDeadLetterQueue for the given processingGroup.
EnqueuePolicy<EventMessage>	DeadLetterQueueConfiguration.enqueuePolicy()	Returns the configured EnqueuePolicy.

Methods in io.axoniq.framework.messaging.eventhandling.deadletter with parameters of type EventMessage

Modifier and Type	Method	Description
MessageStream.Empty<Message>	DeadLetteringEventHandlingComponent.handle(EventMessage event, ProcessingContext context)

Method parameters in io.axoniq.framework.messaging.eventhandling.deadletter with type arguments of type EventMessage

Modifier and Type	Method	Description
DeadLetterQueueConfiguration	DeadLetterQueueConfiguration.enqueuePolicy(EnqueuePolicy<EventMessage> enqueuePolicy)	Sets the EnqueuePolicy to use when deciding whether to dead-letter a failed event.
CompletableFuture<Boolean>	DeadLetteringEventHandlingComponent.process(Predicate<DeadLetter<? extends EventMessage>> sequenceFilter)
CompletableFuture<Boolean>	DeadLetteringEventHandlingComponent.process(Predicate<DeadLetter<? extends EventMessage>> sequenceFilter, @Nullable ProcessingContext context)

Constructor parameters in io.axoniq.framework.messaging.eventhandling.deadletter with type arguments of type EventMessage

Modifier	Constructor	Description
	DeadLetteringEventHandlingComponent(EventHandlingComponent delegate, SequencedDeadLetterQueue<EventMessage> queue, EnqueuePolicy<EventMessage> enqueuePolicy, UnitOfWorkFactory unitOfWorkFactory, boolean allowReset)	Instantiate a DeadLetteringEventHandlingComponent with the given delegate, queue, custom EnqueuePolicy, reset behavior, and unitOfWorkFactory.
	DeadLetteringEventHandlingComponent(EventHandlingComponent delegate, SequencedDeadLetterQueue<EventMessage> queue, EnqueuePolicy<EventMessage> enqueuePolicy, UnitOfWorkFactory unitOfWorkFactory, boolean allowReset)	Instantiate a DeadLetteringEventHandlingComponent with the given delegate, queue, custom EnqueuePolicy, reset behavior, and unitOfWorkFactory.

Uses of EventMessage in io.axoniq.framework.messaging.eventhandling.deadletter.jdbc

Classes in io.axoniq.framework.messaging.eventhandling.deadletter.jdbc with type parameters of type EventMessage

Modifier and Type	Interface	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.
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 a JdbcSequencedDeadLetterQueue.

Methods in io.axoniq.framework.messaging.eventhandling.deadletter.jdbc with type parameters of type EventMessage

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

Uses of EventMessage in io.axoniq.framework.messaging.eventhandling.deadletter.jpa

Classes in io.axoniq.framework.messaging.eventhandling.deadletter.jpa with type parameters of type EventMessage

Modifier and Type	Interface	Description
interface	DeadLetterJpaConverter<M extends EventMessage>	Converter that can convert an 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 io.axoniq.framework.messaging.eventhandling.deadletter.jpa with type parameters of type EventMessage

Modifier and Type	Method	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 io.axoniq.framework.messaging.eventhandling.deadletter.jpa that return types with arguments of type EventMessage

Modifier and Type	Method	Description
MessageStream.Entry<EventMessage>	EventMessageDeadLetterJpaConverter.convert(DeadLetterEventEntry entry, EventConverter eventConverter, Converter genericConverter)

Methods in io.axoniq.framework.messaging.eventhandling.deadletter.jpa with parameters of type EventMessage

Modifier and Type	Method	Description
DeadLetterEventEntry	EventMessageDeadLetterJpaConverter.convert(EventMessage message, @Nullable Context context, EventConverter eventConverter, Converter genericConverter)

Method parameters in io.axoniq.framework.messaging.eventhandling.deadletter.jpa with type arguments of type EventMessage

Modifier and Type	Method	Description
JpaSequencedDeadLetterQueue.Builder<T>	JpaSequencedDeadLetterQueue.Builder.converter(DeadLetterJpaConverter<EventMessage> converter)	Sets the DeadLetterJpaConverter used to convert EventMessages to and from DeadLetterEventEntries.

Uses of EventMessage in io.axoniq.framework.messaging.eventstreaming

Methods in io.axoniq.framework.messaging.eventstreaming that return types with arguments of type EventMessage

Modifier and Type	Method	Description
MessageStream<EventMessage>	MultiStreamableEventSource.open(StreamingCondition condition, @Nullable ProcessingContext context)

Method parameters in io.axoniq.framework.messaging.eventstreaming with type arguments of type EventMessage

Modifier and Type	Method	Description
MultiStreamableEventSource	MultiStreamableEventSource.SourceCollector.comparingUsing(Comparator<MessageStream.Entry<EventMessage>> comparator)	Creates a MultiStreamableEventSource using a custom comparator.

Constructor parameters in io.axoniq.framework.messaging.eventstreaming with type arguments of type EventMessage

Modifier	Constructor	Description
protected	MultiStreamableEventSource(Map<String,StreamableEventSource> eventSources, Comparator<MessageStream.Entry<EventMessage>> eventComparator)	Constructs a MultiStreamableEventSource from the collected sources and comparator.

Uses of EventMessage in io.axoniq.framework.messaging.multitenancy.axonserver.eventstreaming

Method parameters in io.axoniq.framework.messaging.multitenancy.axonserver.eventstreaming with type arguments of type EventMessage

Modifier and Type	Method	Description
Registration	MultiTenantPersistentStreamEventSource.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)	Subscribes the given eventsBatchConsumer to the persistent stream of every tenant, opening a stream for each tenant known to the TenantProvider and for every tenant added while the subscription lasts.

Uses of EventMessage in io.axoniq.framework.messaging.multitenancy.deadletter

Methods in io.axoniq.framework.messaging.multitenancy.deadletter that return types with arguments of type EventMessage

Modifier and Type	Method	Description
SequencedDeadLetterQueue<EventMessage>	TenantAwareSequencedDeadLetterQueueFactory.create(TenantDescriptor tenant, String processorName, Configuration configuration)	Creates the concrete dead-letter queue for the given tenant and processorName.
CompletableFuture<Iterable<Iterable<DeadLetter<? extends EventMessage>>>>	TenantRoutingSequencedDeadLetterQueue.deadLetters(@Nullable ProcessingContext context)
CompletableFuture<Iterable<DeadLetter<? extends EventMessage>>>	TenantRoutingSequencedDeadLetterQueue.deadLetterSequence(Object sequenceIdentifier, @Nullable ProcessingContext context)
SequencedDeadLetterQueue<EventMessage>	TenantRoutingSequencedDeadLetterQueueRegistry.queueFor(String processorName, Configuration configuration, TenantAwareSequencedDeadLetterQueueFactory factory, TenantDescriptor tenant)	Returns the queue of the given tenant for the dead-letter queue identified by the supplied processing group, configuration, and delegate factory.

Method parameters in io.axoniq.framework.messaging.multitenancy.deadletter with type arguments of type EventMessage

Modifier and Type	Method	Description
CompletableFuture<Void>	TenantRoutingSequencedDeadLetterQueue.enqueue(Object sequenceIdentifier, DeadLetter<? extends EventMessage> letter, @Nullable ProcessingContext context)
CompletableFuture<Void>	TenantRoutingSequencedDeadLetterQueue.evict(DeadLetter<? extends EventMessage> letter, @Nullable ProcessingContext context)
CompletableFuture<Boolean>	TenantRoutingSequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends EventMessage>> sequenceFilter, Function<DeadLetter<? extends EventMessage>,CompletableFuture<EnqueueDecision<EventMessage>>> processingTask, @Nullable ProcessingContext context)
CompletableFuture<Boolean>	TenantRoutingSequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends EventMessage>> sequenceFilter, Function<DeadLetter<? extends EventMessage>,CompletableFuture<EnqueueDecision<EventMessage>>> processingTask, @Nullable ProcessingContext context)
CompletableFuture<Boolean>	TenantRoutingSequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends EventMessage>> sequenceFilter, Function<DeadLetter<? extends EventMessage>,CompletableFuture<EnqueueDecision<EventMessage>>> processingTask, @Nullable ProcessingContext context)
CompletableFuture<Void>	TenantRoutingSequencedDeadLetterQueue.requeue(DeadLetter<? extends EventMessage> letter, UnaryOperator<DeadLetter<? extends EventMessage>> letterUpdater, @Nullable ProcessingContext context)
CompletableFuture<Void>	TenantRoutingSequencedDeadLetterQueue.requeue(DeadLetter<? extends EventMessage> letter, UnaryOperator<DeadLetter<? extends EventMessage>> letterUpdater, @Nullable ProcessingContext context)

Uses of EventMessage in io.axoniq.framework.messaging.multitenancy.eventsourcing

Methods in io.axoniq.framework.messaging.multitenancy.eventsourcing that return types with arguments of type EventMessage

Modifier and Type	Method	Description
MessageStream<EventMessage>	MultiTenantEventStorageEngine.source(SourcingCondition condition, @Nullable ProcessingContext context)
MessageStream<EventMessage>	MultiTenantEventStorageEngine.stream(StreamingCondition condition)

Uses of EventMessage in io.axoniq.framework.messaging.transformation.events

Methods in io.axoniq.framework.messaging.transformation.events that return types with arguments of type EventMessage

Modifier and Type	Method	Description
MessageStream<EventMessage>	TransformingEventStore.open(StreamingCondition condition, @Nullable ProcessingContext context)
MessageStream<EventMessage>	EventTransformerChain.transform(MessageStream<? extends EventMessage> stream, @Nullable ProcessingContext context, MessageConverter converter, MessageTypeResolver messageTypeResolver)	Applies the chain to every event in the given stream at read time.

Method parameters in io.axoniq.framework.messaging.transformation.events with type arguments of type EventMessage

Modifier and Type	Method	Description
CompletableFuture<Void>	TransformingEventStore.publish(@Nullable ProcessingContext context, List<? extends EventMessage> events)
Registration	TransformingEventStore.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)
MessageStream<EventMessage>	EventTransformerChain.transform(MessageStream<? extends EventMessage> stream, @Nullable ProcessingContext context, MessageConverter converter, MessageTypeResolver messageTypeResolver)	Applies the chain to every event in the given stream at read time.

Uses of EventMessage in io.axoniq.framework.postgresql

Methods in io.axoniq.framework.postgresql that return types with arguments of type EventMessage

Modifier and Type	Method	Description
MessageStream<EventMessage>	PostgresqlEventStorageEngine.source(SourcingCondition condition, @Nullable ProcessingContext context)
MessageStream<EventMessage>	PostgresqlEventStorageEngine.stream(StreamingCondition condition)

Uses of EventMessage in io.axoniq.framework.workflow.dsl.api

Methods in io.axoniq.framework.workflow.dsl.api that return EventMessage

Modifier and Type	Method	Description
EventMessage	PublishStepDefinition.event()	Returns the value of the event record component.

Methods in io.axoniq.framework.workflow.dsl.api that return types with arguments of type EventMessage

Modifier and Type	Method	Description
BiPredicate<EventMessage,ProcessingContext>	EventCondition.predicate()	Returns the predicate on an EventMessage and its accompanying ProcessingContext through which this condition can be evaluated.

Methods in io.axoniq.framework.workflow.dsl.api with parameters of type EventMessage

Modifier and Type	Method	Description
PublishStepDefinition	PublishStepDefinition.event(EventMessage event)	Returns a copy of this definition with the provided event.

Constructors in io.axoniq.framework.workflow.dsl.api with parameters of type EventMessage

Modifier	Constructor	Description
	PublishStepDefinition(String stepName, EventMessage event)	Fails fast when a mandatory component is null; the package's null-marked contract alone is not enforced at runtime, so a user ignoring it is detected here at construction.

Uses of EventMessage in io.axoniq.framework.workflow.dsl.base

Methods in io.axoniq.framework.workflow.dsl.base with parameters of type EventMessage

Modifier and Type	Method	Description
void	BaseWorkflowContext.awaitPublish(String stepName, EventMessage event, UnaryOperator<PublishStepDefinition> customizer)	Publishes a business event as a durable workflow step and blocks until the step is recorded.
PublishStepDefinition	BaseWorkflowContext.defaultPublishStepDefinition(String stepName, EventMessage event)	Creates the default publish step definition used by the BaseWorkflowContext.publish(String, EventMessage, UnaryOperator) convenience overloads.
WorkflowStepResult	BaseWorkflowContext.publish(String stepName, EventMessage event, UnaryOperator<PublishStepDefinition> customizer)	Publishes a business event as a durable workflow step and returns a handle to await later.

Uses of EventMessage in io.axoniq.framework.workflow.dsl.simple

Methods in io.axoniq.framework.workflow.dsl.simple with parameters of type EventMessage

Modifier and Type	Method	Description
void	SimpleWorkflowContext.awaitPublish(String stepName, EventMessage event)	Publishes a business event as a durable workflow step and blocks until the step is recorded.
WorkflowStepResult	SimpleWorkflowContext.publish(String stepName, EventMessage event)	Publishes a business event as a durable workflow step and returns a handle to await later.

Uses of EventMessage in io.axoniq.framework.workflow.history.inmemory

Methods in io.axoniq.framework.workflow.history.inmemory with parameters of type EventMessage

Modifier and Type	Method	Description
MessageStream.Empty<Message>	WorkflowHistoryProjector.handle(EventMessage event, ProcessingContext context)

Uses of EventMessage in io.axoniq.framework.workflow.runtime.api.execution.context

Methods in io.axoniq.framework.workflow.runtime.api.execution.context that return EventMessage

Modifier and Type	Method	Description
EventMessage	PrimitiveCommands.SimplePublishCommand.event()	Returns the value of the event record component.
EventMessage	PublishPrimitive.PublishCommand.event()	Event to publish.

Methods in io.axoniq.framework.workflow.runtime.api.execution.context with parameters of type EventMessage

Modifier and Type	Method	Description
CompletableFuture<Void>	WorkflowExecution.appendWorkflowEvent(EventMessage event, Context parentContext)	Appends a workflow-owned event from the given parent context.
void	WorkflowExecution.onEvent(EventMessage eventMessage, ProcessingContext processingContext)	Delivers an event to the workflow execution.
static PrimitiveCommands.SimplePublishCommand	PrimitiveCommands.publish(String stepName, EventMessage event)	Factory method to create a PrimitiveCommands.SimplePublishCommand, the parameter object of PublishPrimitive.publish(PublishPrimitive.PublishCommand).

Constructors in io.axoniq.framework.workflow.runtime.api.execution.context with parameters of type EventMessage

Modifier	Constructor	Description
	SimplePublishCommand(String stepName, EventMessage event)	Creates an instance of a SimplePublishCommand record class.

Uses of EventMessage in io.axoniq.framework.workflow.runtime.association

Methods in io.axoniq.framework.workflow.runtime.association that return types with arguments of type EventMessage

Modifier and Type	Method	Description
BiPredicate<EventMessage,ProcessingContext>	SerializedAssociation.asEventMessagePredicate(ValueComparisonOperatorRegistry registry)	Delivers a predicate that can be used to filter event messages.

Methods in io.axoniq.framework.workflow.runtime.association with parameters of type EventMessage

Modifier and Type	Method	Description
Object	MetadataPropertyValueRetriever.apply(EventMessage eventMessage, ProcessingContext processingContext)
Object	PayloadPropertyValueRetriever.apply(EventMessage eventMessage, ProcessingContext processingContext)
Object	ValueRetriever.apply(EventMessage eventMessage, ProcessingContext processingContext)	Retrieves association value from the event message.

Uses of EventMessage in io.axoniq.framework.workflow.runtime.execution

Methods in io.axoniq.framework.workflow.runtime.execution that return types with arguments of type EventMessage

Modifier and Type	Method	Description
BiPredicate<EventMessage,ProcessingContext>	WorkflowConfigurationRegistry.PredicatedWorkflowConfiguration.predicate()	Returns the value of the predicate record component.
SequencingPolicy<EventMessage>	WorkflowEngine.segmentedRouting()	Returns the sequencing policy derived from this engine's workflow definitions, which delivers each event to the segment owning the workflow instance it affects.

Methods in io.axoniq.framework.workflow.runtime.execution with parameters of type EventMessage

Modifier and Type	Method	Description
protected CompletableFuture<Void>	AbstractStepExecutor.appendEvent(EventMessage eventMessage, Context context)	Appends the given eventMessage under its append condition, deriving the append's unit of work from the given context.
CompletableFuture<Void>	SimpleWorkflowExecution.appendWorkflowEvent(EventMessage eventMessage, Context parentContext)
String	MessageWorkflowIdProvider.apply(EventMessage eventMessage)
String	PayloadPropertyWorkflowIdProvider.apply(EventMessage eventMessage)
protected Map<String,@Nullable Object>	AbstractStepExecutor.eventMessagePayload(EventMessage eventMessage)
WorkflowState	EventSourcedWorkflowState.evolve(EventMessage eventMessage, ProcessingContext processingContext)	Applies an event while notifying workflow status listeners.
MessageStream.Empty<Message>	EventHandlingComponentHandlingAny.handle(EventMessage event, ProcessingContext context)
MessageStream.Empty<Message>	WorkflowEngine.handle(EventMessage event, ProcessingContext context)
void	SimpleWorkflowExecution.onEvent(EventMessage eventMessage, ProcessingContext processingContext)
Set<Tag>	WorkflowEventTagResolver.resolve(EventMessage eventMessage)
Object	EventHandlingComponentHandlingAny.sequenceIdentifierFor(EventMessage event, ProcessingContext context)

Constructor parameters in io.axoniq.framework.workflow.runtime.execution with type arguments of type EventMessage

Modifier	Constructor	Description
	PredicatedWorkflowConfiguration(BiPredicate<EventMessage,ProcessingContext> predicate, WorkflowConfiguration<?> configuration)	Creates an instance of a PredicatedWorkflowConfiguration record class.

Uses of EventMessage in io.axoniq.framework.workflow.runtime.util

Methods in io.axoniq.framework.workflow.runtime.util that return EventMessage

Modifier and Type	Method	Description
static EventMessage	EventMessageUtils.cancelledStep(WorkflowEventPublicationContext workflowEventPublicationContext, String stepName, EventNameCustomizer customizer)	Creates a new event message stating that a workflow step has been cancelled.
static EventMessage	EventMessageUtils.cancelledStep(WorkflowEventPublicationContext workflowEventPublicationContext, String stepName, @Nullable Throwable cause, EventNameCustomizer customizer)	Creates a new event message stating that a workflow step has been cancelled, optionally with a cause.
static EventMessage	EventMessageUtils.cancelledWaitForEventStep(WorkflowEventPublicationContext workflowEventPublicationContext, String stepName, @Nullable Throwable cause, EventNameCustomizer customizer)	Creates a cancelled event for a wait-for-event step.
static EventMessage	EventMessageUtils.cancelledWorkflow(WorkflowEventPublicationContext workflowEventPublicationContext, String workflowName, @Nullable Throwable cause, VersionedType workflowDefinitionId, EventNameCustomizer customizer)
static EventMessage	EventMessageUtils.cancelledWorkflow(WorkflowEventPublicationContext workflowEventPublicationContext, String workflowName, VersionedType workflowDefinitionId, EventNameCustomizer customizer)	Creates a new event message stating that a workflow has been cancelled.
static EventMessage	EventMessageUtils.completedStep(WorkflowEventPublicationContext workflowEventPublicationContext, String stepName, Map<String,@Nullable Object> result, @Nullable String resultPayloadReducerName, EventNameCustomizer customizer)	Creates a new event message stating that a workflow step has completed.
static EventMessage	EventMessageUtils.completedWaitForEventStep(WorkflowEventPublicationContext workflowEventPublicationContext, String stepName, Map<String,@Nullable Object> result, @Nullable String resultPayloadReducerName, EventNameCustomizer customizer)	Creates a completed event for a wait-for-event step.
static EventMessage	EventMessageUtils.completedWorkflow(WorkflowEventPublicationContext workflowEventPublicationContext, String workflowName, VersionedType workflowDefinitionId, EventNameCustomizer customizer)	Creates a new event message stating that a workflow has completed successfully.
static EventMessage	EventMessageUtils.failedWorkflow(WorkflowEventPublicationContext workflowEventPublicationContext, String workflowName, Exception exception, VersionedType workflowDefinitionId, EventNameCustomizer customizer)	Creates a new event message stating that a workflow has failed.
static EventMessage	EventMessageUtils.failStep(WorkflowEventPublicationContext workflowEventPublicationContext, String stepName, Throwable exception, EventNameCustomizer customizer)	Creates a new event message stating that a workflow step has failed.
static EventMessage	EventMessageUtils.retryingStep(WorkflowEventPublicationContext workflowEventPublicationContext, String stepName, StepRetryInfo retryInfo, EventNameCustomizer customizer)	Creates a new event message stating that a workflow step is retrying.
static EventMessage	EventMessageUtils.retryStartedStep(WorkflowEventPublicationContext workflowEventPublicationContext, String stepName, StepRetryInfo retryInfo, EventNameCustomizer customizer)	Creates a new event message stating that a retry attempt of a workflow step has started.
static EventMessage	EventMessageUtils.startedStep(WorkflowEventPublicationContext workflowEventPublicationContext, String stepName, Map<String,@Nullable Object> local, EventNameCustomizer customizer)	Creates a new event message stating that a workflow step has started.
static EventMessage	EventMessageUtils.startedWaitForEventStep(WorkflowEventPublicationContext workflowEventPublicationContext, String stepName, Map<String,@Nullable Object> local, EventNameCustomizer customizer)	Creates a new started event for a wait-for-event step.
static EventMessage	EventMessageUtils.startedWorkflow(WorkflowEventPublicationContext workflowEventPublicationContext, String workflowName, VersionedType workflowDefinitionId, EventNameCustomizer customizer)	Creates a new event message stating that a workflow has started.
static EventMessage	EventMessageUtils.timeoutStep(WorkflowEventPublicationContext workflowEventPublicationContext, String stepName, Instant time, EventNameCustomizer customizer)	Creates a new event message stating that a workflow step has timed out.
static EventMessage	EventMessageUtils.timeoutWaitForEventStep(WorkflowEventPublicationContext workflowEventPublicationContext, String stepName, Instant time, EventNameCustomizer customizer)	Creates a timed-out event for a wait-for-event step.
static EventMessage	EventMessageUtils.timeoutWorkflow(WorkflowEventPublicationContext workflowEventPublicationContext, String workflowName, Instant time, VersionedType workflowDefinitionId, EventNameCustomizer customizer)	Creates a new event message stating that a workflow has timed out.
static EventMessage	EventMessageUtils.versionMigrationStep(WorkflowEventPublicationContext workflowEventPublicationContext, String changeId, String version, EventNameCustomizer customizer)	Creates a new event message recording a migration step for the given changeId.

Methods in io.axoniq.framework.workflow.runtime.util that return types with arguments of type EventMessage

Modifier and Type	Method	Description
static Predicate<EventMessage>	EventMessageUtils.workflowIdFilter(String workflowId)	Creates a filter predicate for event messages based on the workflow ID.

Uses of EventMessage in org.axonframework.deadline

Subinterfaces of EventMessage in org.axonframework.deadline

Modifier and Type	Interface	Description
interface	DeadlineMessage	An EventMessage for a deadline, specified by its deadlineName and optionally containing a deadlinePayload.

Classes in org.axonframework.deadline that implement EventMessage

Modifier and Type	Class	Description
class	GenericDeadlineMessage	Generic implementation of the DeadlineMessage interface.

Uses of EventMessage in org.axonframework.eventsourcing

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

Modifier and Type	Method	Description
@Nullable E	EventSourcedEntityFactory.create(ID id, @Nullable EventMessage firstEventMessage, ProcessingContext context)	Creates an entity of type E with the given identifier.

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

Modifier and Type	Method	Description
static <ID, E> EventSourcedEntityFactory<ID,E>	EventSourcedEntityFactory.fromEventMessage(BiFunction<ID,EventMessage,E> creator)	Creates a factory for an entity of type E using a specified constructor with the identifier and the event message as parameters.

Uses of EventMessage in org.axonframework.eventsourcing.annotation.reflection

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

Modifier and Type	Method	Description
@Nullable E	AnnotationBasedEventSourcedEntityFactory.create(ID id, @Nullable EventMessage firstEventMessage, ProcessingContext context)

Uses of EventMessage in org.axonframework.eventsourcing.eventstore

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

Modifier and Type	Class	Description
final record	GenericTaggedEventMessage<E extends EventMessage>	Implementation of the TaggedEventMessage allowing a generic EventMessage of type E.
interface	TaggedEventMessage<E extends EventMessage>	A wrapper of an EventMessage and its Tags.

Classes in org.axonframework.eventsourcing.eventstore that implement EventMessage

Modifier and Type	Class	Description
class	SnapshotEventMessage	Message containing a snapshot.
class	TerminalEventMessage	Empty EventMessage implementation without any payload, used as the terminal message of a MessageStream.

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

Modifier and Type	Method	Description
EventMessage	TooManyTagsOnEventMessageException.eventMessage()	Returns the message that was rejected by the storage engine.

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

Modifier and Type	Method	Description
Optional<EventMessage>	AppendEventsTransactionRejectedException.conflictingEvent()	The first event matching the criteria found beyond the violated consistency marker, if looked up; empty otherwise.
protected AbstractMessageStream.FetchResult<MessageStream.Entry<EventMessage>>	ContinuousMessageStream.fetchNext()
MessageStream<EventMessage>	InterceptingEventStore.open(StreamingCondition condition, @Nullable ProcessingContext context)
MessageStream<EventMessage>	StorageEngineBackedEventStore.open(StreamingCondition condition, @Nullable ProcessingContext context)
MessageStream<EventMessage>	ConflictDiagnosingEventStorageEngine.source(SourcingCondition condition, @Nullable ProcessingContext context)
MessageStream<? extends EventMessage>	DefaultEventStoreTransaction.source(SourcingCondition condition)
MessageStream<? extends EventMessage>	DefaultEventStoreTransaction.source(SourcingCondition condition, @Nullable Consumer<Position> resumePositionCallback)
default MessageStream<EventMessage>	EventStorageEngine.source(SourcingCondition condition)	Creates a finite MessageStream of events matching the given condition.
MessageStream<EventMessage>	EventStorageEngine.source(SourcingCondition condition, @Nullable ProcessingContext context)	Creates a finite MessageStream of events matching the given condition, carrying along the active ProcessingContext.
default MessageStream<? extends EventMessage>	EventStoreTransaction.source(SourcingCondition condition)	Sources a MessageStream of type EventMessage based on the given condition that can be used to rehydrate a model.
MessageStream<? extends EventMessage>	EventStoreTransaction.source(SourcingCondition condition, @Nullable Consumer<Position> resumePositionCallback)	Sources a MessageStream of type EventMessage based on the given condition, optionally invoking the given resume position callback.
MessageStream<EventMessage>	SnapshotCapableEventStorageEngine.source(SourcingCondition condition, @Nullable ProcessingContext context)
MessageStream<EventMessage>	ConflictDiagnosingEventStorageEngine.stream(StreamingCondition condition)
MessageStream<EventMessage>	EventStorageEngine.stream(StreamingCondition condition)	Creates an infinite MessageStream of events matching the given condition.
MessageStream<EventMessage>	SnapshotCapableEventStorageEngine.stream(StreamingCondition condition)

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

Modifier and Type	Method	Description
void	DefaultEventStoreTransaction.appendEvent(EventMessage eventMessage)
void	EventStoreTransaction.appendEvent(EventMessage eventMessage)	Appends an eventMessage to be appended to an EventStore in this transaction.
Set<Tag>	AnnotationBasedTagResolver.resolve(EventMessage event)
Set<Tag>	MetadataBasedTagResolver.resolve(EventMessage event)
Set<Tag>	MultiTagResolver.resolve(EventMessage event)
Set<Tag>	PayloadBasedTagResolver.resolve(EventMessage event)
Set<Tag>	TagResolver.resolve(EventMessage event)	Resolves a Set of Tags for the given event.
default Set<Tag>	TagResolver.resolve(EventMessage event, @Nullable ProcessingContext context)	Resolves a Set of Tags for the given event, caching the result in the given context so repeated resolutions of the same event within one unit of work are computed only once.
AppendEventsTransactionRejectedException	AppendEventsTransactionRejectedException.withConflictingEvent(@Nullable EventMessage conflictingEvent)	Returns a copy of this AppendEventsTransactionRejectedException with its AppendEventsTransactionRejectedException.conflictingEvent() replaced by the given conflictingEvent, preserving the original message, AppendEventsTransactionRejectedException.tags(), stack trace, and cause.

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

Modifier and Type	Method	Description
void	DefaultEventStoreTransaction.onAppend(Consumer<EventMessage> callback)
void	EventStoreTransaction.onAppend(Consumer<EventMessage> callback)	Registers a callback to invoke when an event is appended to this transaction.
CompletableFuture<Void>	InterceptingEventStore.publish(@Nullable ProcessingContext context, List<? extends EventMessage> events)
CompletableFuture<Void>	StorageEngineBackedEventStore.publish(@Nullable ProcessingContext context, List<? extends EventMessage> events)
Registration	InterceptingEventStore.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)
Registration	StorageEngineBackedEventStore.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)

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

Modifier	Constructor	Description
	TooManyTagsOnEventMessageException(String message, EventMessage eventMessage, Set<Tag> tags)	Initialize the exception with given explanatory message for logging, referencing the given eventMessage and tags for debug purposes.

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

Modifier	Constructor	Description
	ContinuousMessageStream(Supplier<List<E>> fetcher, Function<E,MessageStream.Entry<EventMessage>> converter, BiFunction<ContinuousMessageStream<?>,Runnable,Registration> callbackTracker)	Creates a new ContinuousMessageStream instance configured with the given strategies.
	DefaultEventStoreTransaction(EventStorageEngine eventStorageEngine, ProcessingContext processingContext, Function<EventMessage,TaggedEventMessage<?>> eventTagger)	Constructs a DefaultEventStoreTransaction using the given eventStorageEngine to append events originating from the given context.
	InterceptingEventStore(EventStore delegate, List<MessageDispatchInterceptor<? super EventMessage>> interceptors)	Constructs a InterceptingEventStore, delegating all operation to the given delegate.

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

Methods in org.axonframework.eventsourcing.eventstore.inmemory that return types with arguments of type EventMessage

Modifier and Type	Method	Description
MessageStream<EventMessage>	InMemoryEventStorageEngine.source(SourcingCondition condition, @Nullable ProcessingContext context)
MessageStream<EventMessage>	InMemoryEventStorageEngine.stream(StreamingCondition condition)

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

Methods in org.axonframework.eventsourcing.eventstore.jpa that return types with arguments of type EventMessage

Modifier and Type	Method	Description
MessageStream<EventMessage>	AggregateBasedJpaEventStorageEngine.source(SourcingCondition condition, @Nullable ProcessingContext context)
MessageStream<EventMessage>	AggregateBasedJpaEventStorageEngine.stream(StreamingCondition condition)

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

Methods in org.axonframework.eventsourcing.eventstore.tracing that return types with arguments of type EventMessage

Modifier and Type	Method	Description
MessageStream<EventMessage>	TracingEventStore.open(StreamingCondition condition, @Nullable ProcessingContext context)
MessageStream<EventMessage>	TracingEventStorageEngine.source(SourcingCondition condition, @Nullable ProcessingContext context)
MessageStream<EventMessage>	TracingEventStorageEngine.stream(StreamingCondition condition)

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

Modifier and Type	Method	Description
CompletableFuture<Void>	TracingEventStore.publish(@Nullable ProcessingContext context, List<? extends EventMessage> events)
Registration	TracingEventStore.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)

Uses of EventMessage in org.axonframework.eventsourcing.handler

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

Modifier and Type	Method	Description
E	InitializingEntityEvolver.evolve(I identifier, @Nullable E entity, EventMessage message, ProcessingContext context)	Initializes or evolves the given entity using the given message.

Uses of EventMessage in org.axonframework.eventsourcing.snapshot.api

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

Modifier and Type	Method	Description
default boolean	SnapshotPolicy.shouldSnapshot(EventMessage event)	Allows triggering a snapshot when sourcing completes, based on an event seen during sourcing.

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

Modifier and Type	Method	Description
static SnapshotPolicy	SnapshotPolicy.whenEventMatches(Predicate<EventMessage> predicate)	Creates a policy that triggers a snapshot when the predicate matches an event encountered during sourcing.

Uses of EventMessage in org.axonframework.extension.metrics.dropwizard

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

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

Uses of EventMessage in org.axonframework.extension.metrics.micrometer

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

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

Uses of EventMessage in org.axonframework.extension.reactor.messaging.core.interception

Methods in org.axonframework.extension.reactor.messaging.core.interception that return types with arguments of type EventMessage

Modifier and Type	Method	Description
List<ReactorMessageDispatchInterceptor<? super EventMessage>>	DefaultReactorDispatchInterceptorRegistry.eventInterceptors(Configuration config, Class<?> componentType, @Nullable String componentName)
List<ReactorMessageDispatchInterceptor<? super EventMessage>>	ReactorDispatchInterceptorRegistry.eventInterceptors(Configuration config, Class<?> componentType, @Nullable String componentName)	Returns the list of ReactorMessageDispatchInterceptors registered for EventMessages for a specific componentType and componentName.

Method parameters in org.axonframework.extension.reactor.messaging.core.interception with type arguments of type EventMessage

Modifier and Type	Method	Description
ReactorDispatchInterceptorRegistry	DefaultReactorDispatchInterceptorRegistry.registerEventInterceptor(ComponentBuilder<ReactorMessageDispatchInterceptor<? super EventMessage>> interceptorBuilder)
ReactorDispatchInterceptorRegistry	DefaultReactorDispatchInterceptorRegistry.registerEventInterceptor(ReactorDispatchInterceptorFactory<? super EventMessage> interceptorFactory)
ReactorDispatchInterceptorRegistry	ReactorDispatchInterceptorRegistry.registerEventInterceptor(ComponentBuilder<ReactorMessageDispatchInterceptor<? super EventMessage>> interceptorBuilder)	Registers the given interceptorBuilder for an EventMessage-specific ReactorMessageDispatchInterceptor.
ReactorDispatchInterceptorRegistry	ReactorDispatchInterceptorRegistry.registerEventInterceptor(ReactorDispatchInterceptorFactory<? super EventMessage> interceptorFactory)	Registers the given component-aware interceptorFactory for an EventMessage-specific ReactorMessageDispatchInterceptor.

Uses of EventMessage in org.axonframework.extension.reactor.messaging.eventhandling.gateway

Constructor parameters in org.axonframework.extension.reactor.messaging.eventhandling.gateway with type arguments of type EventMessage

Modifier	Constructor	Description
	DefaultReactorEventGateway(EventGateway eventGateway, MessageTypeResolver messageTypeResolver, List<ReactorMessageDispatchInterceptor<? super EventMessage>> dispatchInterceptors)	Instantiate a DefaultReactorEventGateway.

Uses of EventMessage in org.axonframework.extension.spring.messaging

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

Modifier and Type	Method	Description
<T> EventMessage	DefaultEventMessageConverter.convertFromInboundMessage(org.springframework.messaging.Message message)
<T> EventMessage	EventMessageConverter.convertFromInboundMessage(org.springframework.messaging.Message message)	Converts a Spring inbound message into an Axon event 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.extension.spring.messaging with parameters of type EventMessage

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

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

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

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

Modifier	Constructor	Description
	InboundEventMessageChannelAdapter(List<BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>>> processors, EventMessageConverter eventMessageConverter)	Initialize the adapter to publish all incoming events to the subscribed processors.
	OutboundEventMessageChannelAdapter(SubscribableEventSource eventSource, org.springframework.messaging.MessageChannel channel, Predicate<? super EventMessage> filter)	Initialize an adapter to forward messages from the given eventSource to the given channel.
	OutboundEventMessageChannelAdapter(SubscribableEventSource eventSource, org.springframework.messaging.MessageChannel channel, Predicate<? super EventMessage> filter, EventMessageConverter eventMessageConverter)	Initialize an adapter to forward messages from the given eventSource to the given channel.

Uses of EventMessage in org.axonframework.messaging.core

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

Modifier and Type	Method	Description
Registration	SubscribableEventSource.subscribe(BiFunction<List<? extends EventMessage>,@Nullable ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)	Subscribe the given eventsBatchConsumer to this event source.

Uses of EventMessage in org.axonframework.messaging.core.configuration

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

Modifier and Type	Method	Description
MessagingConfigurer	MessagingConfigurer.registerEventDispatchInterceptor(ComponentBuilder<MessageDispatchInterceptor<? super EventMessage>> interceptorBuilder)	Registers the given EventMessage-specific MessageDispatchInterceptor builder in this Configurer.
MessagingConfigurer	MessagingConfigurer.registerEventHandlerInterceptor(ComponentBuilder<MessageHandlerInterceptor<? super EventMessage>> interceptorBuilder)	Registers the given EventMessage MessageHandlerInterceptor builder in this Configurer.
MessagingConfigurer	MessagingConfigurer.registerEventMonitor(ComponentBuilder<MessageMonitor<? super EventMessage>> monitorBuilder)	Registers a event MessageMonitor builder for all event-specific infrastructure components component in this configuration.
MessagingConfigurer	MessagingConfigurer.registerEventMonitor(MessageMonitorFactory<? super EventMessage> monitorFactory)	Registers a message monitor factory for event-specific infrastructure components in this configuration.

Uses of EventMessage in org.axonframework.messaging.core.interception

Methods in org.axonframework.messaging.core.interception that return types with arguments of type EventMessage

Modifier and Type	Method	Description
List<MessageDispatchInterceptor<? super EventMessage>>	DefaultDispatchInterceptorRegistry.eventInterceptors(Configuration config, Class<?> componentType, @Nullable String componentName)
List<MessageHandlerInterceptor<? super EventMessage>>	DefaultHandlerInterceptorRegistry.eventInterceptors(Configuration config, Class<?> componentType, @Nullable String componentName)
List<MessageDispatchInterceptor<? super EventMessage>>	DispatchInterceptorRegistry.eventInterceptors(Configuration config, Class<?> componentType, @Nullable String componentName)	Returns the list of EventMessage-specific MessageDispatchInterceptors registered in this registry for a specific componentType and componentName.
List<MessageHandlerInterceptor<? super EventMessage>>	HandlerInterceptorRegistry.eventInterceptors(Configuration config, Class<?> componentType, @Nullable String componentName)	Returns the list of EventMessage-specific MessageHandlerInterceptors registered in this registry for a componentType and componentName.

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

Modifier and Type	Method	Description
DispatchInterceptorRegistry	DefaultDispatchInterceptorRegistry.registerEventInterceptor(ComponentBuilder<MessageDispatchInterceptor<? super EventMessage>> interceptorBuilder)
DispatchInterceptorRegistry	DefaultDispatchInterceptorRegistry.registerEventInterceptor(DispatchInterceptorFactory<? super EventMessage> interceptorFactory)
HandlerInterceptorRegistry	DefaultHandlerInterceptorRegistry.registerEventInterceptor(ComponentBuilder<MessageHandlerInterceptor<? super EventMessage>> interceptorBuilder)
HandlerInterceptorRegistry	DefaultHandlerInterceptorRegistry.registerEventInterceptor(HandlerInterceptorFactory<? super EventMessage> interceptorFactory)
DispatchInterceptorRegistry	DispatchInterceptorRegistry.registerEventInterceptor(ComponentBuilder<MessageDispatchInterceptor<? super EventMessage>> interceptorBuilder)	Registers the given interceptorBuilder for a EventMessage-specific MessageDispatchInterceptor.
DispatchInterceptorRegistry	DispatchInterceptorRegistry.registerEventInterceptor(DispatchInterceptorFactory<? super EventMessage> interceptorFactory)	Registers the given component-aware interceptorFactory for a EventMessage-specific MessageDispatchInterceptor.
HandlerInterceptorRegistry	HandlerInterceptorRegistry.registerEventInterceptor(ComponentBuilder<MessageHandlerInterceptor<? super EventMessage>> interceptorBuilder)	Registers the given interceptorBuilder for a EventMessage MessageHandlerInterceptor for all event handling infrastructure components.
HandlerInterceptorRegistry	HandlerInterceptorRegistry.registerEventInterceptor(HandlerInterceptorFactory<? super EventMessage> interceptorFactory)	Registers the given component-aware interceptorFactory for a EventMessage MessageHandlerInterceptor for all event handling infrastructure components.

Uses of EventMessage in org.axonframework.messaging.core.sequencing

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

Modifier and Type	Method	Description
Optional<Object>	SequentialPerAggregatePolicy.sequenceIdentifierFor(EventMessage message, ProcessingContext context)

Uses of EventMessage in org.axonframework.messaging.eventhandling

Classes in org.axonframework.messaging.eventhandling that implement EventMessage

Modifier and Type	Class	Description
class	GenericEventMessage	Generic implementation of the EventMessage interface.

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

Modifier and Type	Method	Description
EventMessage	EventMessage.andMetadata(Map<String,@Nullable String> metadata)
EventMessage	GenericEventMessage.andMetadata(Map<String,String> metadata)
default EventMessage	EventMessage.withConvertedPayload(Class<?> type, Converter converter)
EventMessage	EventMessage.withConvertedPayload(Type type, Converter converter)
default EventMessage	EventMessage.withConvertedPayload(TypeReference<?> type, Converter converter)
EventMessage	GenericEventMessage.withConvertedPayload(Type type, Converter converter)
EventMessage	EventMessage.withMetadata(Map<String,@Nullable String> metadata)
EventMessage	GenericEventMessage.withMetadata(Map<String,String> metadata)

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

Modifier and Type	Method	Description
MessageStream.Empty<Message>	DelegatingEventHandlingComponent.handle(EventMessage event, ProcessingContext context)
MessageStream.Empty<Message>	EventHandler.handle(EventMessage event, ProcessingContext context)	Handles the given event within the given context.
MessageStream.Empty<Message>	EventHandlingExceptionHandler.handle(EventMessage event, ProcessingContext context, Throwable error)	Called when an event handler throws an exception.
MessageStream.Empty<Message>	SimpleEventHandlingComponent.handle(EventMessage event, ProcessingContext context)
default CompletableFuture<Void>	EventSink.publish(@Nullable ProcessingContext context, EventMessage @Nullable ... events)	Publishes the given events within the given context, when present.
Object	DelegatingEventHandlingComponent.sequenceIdentifierFor(EventMessage event, ProcessingContext context)
Object	EventHandlingComponent.sequenceIdentifierFor(EventMessage event, ProcessingContext context)	Returns the sequence identifier for the given event.
Object	SimpleEventHandlingComponent.sequenceIdentifierFor(EventMessage event, ProcessingContext context)	Returns the sequence identifier for the given event.

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

Modifier and Type	Method	Description
static SimpleEventHandlingComponent	SimpleEventHandlingComponent.create(String name, SequencingPolicy<? super EventMessage> sequencingPolicy)	Instantiates a simple EventHandlingComponent that is able to handle events and delegate them to subcomponents, using the given sequencingPolicy to decide how to sequence incoming events.
SimpleEventHandlingComponent	SimpleEventHandlingComponent.overridePolicyWhenDefault(SequencingPolicy<? super EventMessage> sequencingPolicy)	Replaces the default SequencingPolicy of a SimpleEventHandlingComponent with the given sequencingPolicy, only if the default is in place.
CompletableFuture<Void>	DelegatingEventBus.publish(@Nullable ProcessingContext context, List<? extends EventMessage> events)
CompletableFuture<Void>	EventSink.publish(@Nullable ProcessingContext context, List<? extends EventMessage> events)	Publishes the given events within the given context, when present.
CompletableFuture<Void>	InterceptingEventBus.publish(@Nullable ProcessingContext context, List<? extends EventMessage> events)
CompletableFuture<Void>	InterceptingEventSink.publish(@Nullable ProcessingContext context, List<? extends EventMessage> events)
CompletableFuture<Void>	SimpleEventBus.publish(@Nullable ProcessingContext context, List<? extends EventMessage> events)
Registration	DelegatingEventBus.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)
Registration	InterceptingEventBus.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)
Registration	SimpleEventBus.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)

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

Modifier	Constructor	Description
	InterceptingEventBus(EventBus delegate, List<MessageDispatchInterceptor<? super EventMessage>> interceptors)	Constructs a InterceptingEventBus, delegating all operations to the given delegate.
	InterceptingEventSink(EventSink delegate, List<MessageDispatchInterceptor<? super EventMessage>> interceptors)	Constructs a InterceptingEventSink, delegating publishing to the given delegate.
protected	SimpleEventHandlingComponent(String name, SequencingPolicy<? super EventMessage> sequencingPolicy)

Uses of EventMessage in org.axonframework.messaging.eventhandling.annotation

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

Modifier and Type	Method	Description
MessageStream.Empty<Message>	AnnotatedEventHandlingComponent.handle(EventMessage event, ProcessingContext context)
Object	AnnotatedEventHandlingComponent.sequenceIdentifierFor(EventMessage event, ProcessingContext context)

Uses of EventMessage in org.axonframework.messaging.eventhandling.configuration

Fields in org.axonframework.messaging.eventhandling.configuration with type parameters of type EventMessage

Modifier and Type	Field	Description
protected BiFunction<Class<? extends EventProcessor>,String,List<MessageHandlerInterceptor<? super EventMessage>>>	EventProcessorConfiguration.interceptorBuilder
protected List<MessageHandlerInterceptor<? super EventMessage>>	EventProcessorConfiguration.interceptors
protected BiFunction<Class<? extends EventProcessor>,String,MessageMonitor<? super EventMessage>>	EventProcessorConfiguration.monitorBuilder

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

Modifier and Type	Method	Description
EventHandlingComponentsConfigurer.CompletePhase	DefaultEventHandlingComponentsConfigurer.intercepted(ComponentBuilder<MessageHandlerInterceptor<? super EventMessage>> interceptorBuilder)
EventHandlingComponentsConfigurer.CompletePhase	EventHandlingComponentsConfigurer.CompletePhase.intercepted(ComponentBuilder<MessageHandlerInterceptor<? super EventMessage>> interceptorBuilder)	Registers an interceptor to be applied to all event handling components in this configurer.
default EventHandlingComponentsConfigurer.CompletePhase	EventHandlingComponentsConfigurer.CompletePhase.withExceptionHandler(ComponentBuilder<? extends MessageHandlingExceptionHandler<? super EventMessage>> handlerBuilder)	Wraps all event handling components with the exception handler built by the given handlerBuilder.

Uses of EventMessage in org.axonframework.messaging.eventhandling.conversion

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

Modifier and Type	Method	Description
<E extends EventMessage> E	DelegatingEventConverter.convertEvent(E event, Type targetType)
default <E extends EventMessage, T> E	EventConverter.convertEvent(E event, Class<T> targetType)	Converts the given event's payload to the given targetType, returning a new EventMessage with the converted payload.
<E extends EventMessage> E	EventConverter.convertEvent(E event, Type targetType)	Converts the given event's payload to the given targetType, returning a new EventMessage with the converted payload.
<E extends EventMessage, T> @Nullable T	DelegatingEventConverter.convertPayload(E event, Type targetType)
default <E extends EventMessage, T> @Nullable T	EventConverter.convertPayload(E event, Class<T> targetType)	Converts the given event's payload into a payload of the given targetType.
<E extends EventMessage, T> @Nullable T	EventConverter.convertPayload(E event, Type targetType)	Converts the given event's payload into a payload of the given targetType.

Uses of EventMessage in org.axonframework.messaging.eventhandling.interception

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

Modifier and Type	Method	Description
MessageStream.Empty<Message>	InterceptingEventHandlingComponent.handle(EventMessage event, ProcessingContext context)
MessageStream<?>	EventMessageHandlerInterceptorChain.proceed(EventMessage event, ProcessingContext context)

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

Modifier	Constructor	Description
	EventMessageHandlerInterceptorChain(List<MessageHandlerInterceptor<? super EventMessage>> interceptors, EventHandler eventHandler)	Constructs a new EventMessageHandlerInterceptorChain with a list of interception and an eventHandler.
	InterceptingEventHandlingComponent(List<MessageHandlerInterceptor<? super EventMessage>> interceptors, EventHandlingComponent delegate)	Constructs the component with the given delegate and interceptors.

Uses of EventMessage in org.axonframework.messaging.eventhandling.processing

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

Modifier and Type	Method	Description
Set<Object>	ProcessorEventHandlingComponents.sequenceIdentifiersFor(EventMessage event, ProcessingContext context)	Retrieves a set of sequence identifiers for the given event message and processing context.

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

Modifier and Type	Method	Description
MessageStream.Empty<Message>	ProcessorEventHandlingComponents.handle(List<MessageStream.Entry<? extends EventMessage>> entries, ProcessingContext context)	Processes a batch of events in the given processing context.

Uses of EventMessage in org.axonframework.messaging.eventhandling.processing.errorhandling

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

Modifier and Type	Method	Description
List<? extends EventMessage>	ErrorContext.failedEvents()	Returns the value of the failedEvents record component.

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

Modifier	Constructor	Description
	ErrorContext(String eventProcessor, Throwable error, List<? extends EventMessage> failedEvents, Context context)	Compact constructor of the ErrorContext to validate the eventProcessor, error, failedEvents, and context are not null.

Uses of EventMessage in org.axonframework.messaging.eventhandling.processing.streaming.pooled

Methods in org.axonframework.messaging.eventhandling.processing.streaming.pooled that return types with arguments of type EventMessage

Modifier and Type	Method	Description
Consumer<? super EventMessage>	PooledStreamingEventProcessorConfiguration.ignoredMessageHandler()	Returns the handler for ignored messages.
List<MessageHandlerInterceptor<? super EventMessage>>	PooledStreamingEventProcessorConfiguration.interceptors()	Returns the list of EventMessage-specific MessageHandlerInterceptors to add to the PooledStreamingEventProcessor under construction with this configuration implementation.
@Nullable SequencingPolicy<? super EventMessage>	PooledStreamingEventProcessorConfiguration.sequencingPolicy()	Returns the SequencingPolicy this processor applies to assigned EventHandlingComponents that do not define a more specific one.

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

Modifier and Type	Method	Description
PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.ignoredMessageHandler(Consumer<? super EventMessage> ignoredMessageHandler)	Sets the handler, that is invoked when the event is ignored by all WorkPackages this Coordinator controls.
PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.sequencingPolicy(SequencingPolicy<? super EventMessage> sequencingPolicy)	Sets the SequencingPolicy used to determine the sequence identifier of events handled by this PooledStreamingEventProcessor, whenever an assigned EventHandlingComponent does not define a more specific one.
PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.withInterceptor(MessageHandlerInterceptor<? super EventMessage> interceptor)	Registers the given EventMessage-specific MessageHandlerInterceptor for the PooledStreamingEventProcessor under construction.

Uses of EventMessage in org.axonframework.messaging.eventhandling.processing.streaming.segmenting

Methods in org.axonframework.messaging.eventhandling.processing.streaming.segmenting with parameters of type EventMessage

Modifier and Type	Method	Description
MessageStream.Empty<Message>	SequenceOverridingEventHandlingComponent.handle(EventMessage event, ProcessingContext context)
MessageStream.Empty<Message>	SequencingEventHandlingComponent.handle(EventMessage event, ProcessingContext context)
Object	SequenceCachingEventHandlingComponent.sequenceIdentifierFor(EventMessage event, ProcessingContext context)
Object	SequenceOverridingEventHandlingComponent.sequenceIdentifierFor(EventMessage event, ProcessingContext context)

Constructor parameters in org.axonframework.messaging.eventhandling.processing.streaming.segmenting with type arguments of type EventMessage

Modifier	Constructor	Description
	SequenceOverridingEventHandlingComponent(SequencingPolicy<? super EventMessage> sequencingPolicy, EventHandlingComponent delegate)	Creates a new SequenceOverridingEventHandlingComponent that uses the given sequencingPolicy to override sequence identification while delegating all other operations to the delegate component.

Uses of EventMessage in org.axonframework.messaging.eventhandling.processing.subscribing

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

Modifier and Type	Method	Description
Consumer<? super EventMessage>	SubscribingEventProcessorConfiguration.ignoredMessageHandler()	Returns the handler for ignored messages.
List<MessageHandlerInterceptor<? super EventMessage>>	SubscribingEventProcessorConfiguration.interceptors()	Returns the list of EventMessage-specific MessageHandlerInterceptors to add to the SubscribingEventProcessor under construction with this configuration implementation.

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

Modifier and Type	Method	Description
SubscribingEventProcessorConfiguration	SubscribingEventProcessorConfiguration.ignoredMessageHandler(Consumer<? super EventMessage> ignoredMessageHandler)	Sets the handler, that is invoked when the event is ignored by all EventHandlingComponents this SubscribingEventProcessor controls.
protected void	SubscribingEventProcessor.process(List<EventMessage> eventMessages, @Nullable ProcessingContext context)	Deprecated, for removal: This API element is subject to removal in a future version. in favor of SubscribingEventProcessor.processAsync(List, ProcessingContext), which reports completion and failures through the returned CompletableFuture rather than blocking the calling thread.
protected CompletableFuture<Void>	SubscribingEventProcessor.processAsync(List<EventMessage> eventMessages, @Nullable ProcessingContext context)	Process the given messages, returning a CompletableFuture that completes when processing is done.
SubscribingEventProcessorConfiguration	SubscribingEventProcessorConfiguration.withInterceptor(MessageHandlerInterceptor<? super EventMessage> interceptor)	Registers the given EventMessage-specific MessageHandlerInterceptor for the SubscribingEventProcessor under construction.

Uses of EventMessage in org.axonframework.messaging.eventhandling.replay

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

Modifier and Type	Method	Description
MessageStream.Empty<Message>	ReplayBlockingEventHandlingComponent.handle(EventMessage event, ProcessingContext context)	Handles the given event unless a replay is in progress.

Uses of EventMessage in org.axonframework.messaging.eventhandling.tracing

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

Modifier and Type	Method	Description
MessageStream.Empty<Message>	TracingEventHandlingComponent.handle(EventMessage event, ProcessingContext context)

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

Modifier and Type	Method	Description
CompletableFuture<Void>	TracingEventBus.publish(@Nullable ProcessingContext context, List<? extends EventMessage> events)
CompletableFuture<Void>	TracingEventSink.publish(@Nullable ProcessingContext context, List<? extends EventMessage> events)
Registration	TracingEventBus.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)

Uses of EventMessage in org.axonframework.messaging.eventstreaming

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

Modifier and Type	Method	Description
MessageStream<EventMessage>	StreamableEventSource.open(StreamingCondition condition, @Nullable ProcessingContext context)	Open an event stream containing all events matching the given condition.

Uses of EventMessage in org.axonframework.messaging.monitoring.configuration

Methods in org.axonframework.messaging.monitoring.configuration that return types with arguments of type EventMessage

Modifier and Type	Method	Description
MessageMonitor<? super EventMessage>	DefaultMessageMonitorRegistry.eventMonitor(Configuration config, Class<?> componentType, @Nullable String componentName)
MessageMonitor<? super EventMessage>	MessageMonitorRegistry.eventMonitor(Configuration config, Class<?> componentType, @Nullable String componentName)	Retrieves a MessageMonitor specifically designed to monitor the processing of EventMessage instances for a specific componentType and componentName.

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

Modifier and Type	Method	Description
MessageMonitorRegistry	DefaultMessageMonitorRegistry.registerEventMonitor(ComponentBuilder<MessageMonitor<? super EventMessage>> monitorBuilder)
MessageMonitorRegistry	DefaultMessageMonitorRegistry.registerEventMonitor(MessageMonitorFactory<? super EventMessage> monitorFactory)
MessageMonitorRegistry	MessageMonitorRegistry.registerEventMonitor(ComponentBuilder<MessageMonitor<? super EventMessage>> monitorBuilder)	Registers a MessageMonitor specific for EventMessage types using the supplied monitor builder.
MessageMonitorRegistry	MessageMonitorRegistry.registerEventMonitor(MessageMonitorFactory<? super EventMessage> monitorFactory)	Registers a component-aware MessageMonitor specifically for monitoring the processing of EventMessage instances using the given monitorFactory.

Uses of EventMessage in org.axonframework.messaging.monitoring.interception

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

Modifier and Type	Method	Description
MessageStream<?>	MonitoringEventDispatchInterceptor.interceptOnDispatch(EventMessage message, @Nullable ProcessingContext context, MessageDispatchInterceptorChain<EventMessage> interceptorChain)
MessageStream<?>	MonitoringEventHandlerInterceptor.interceptOnHandle(EventMessage message, ProcessingContext context, MessageHandlerInterceptorChain<EventMessage> interceptorChain)

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

Modifier and Type	Method	Description
MessageStream<?>	MonitoringEventDispatchInterceptor.interceptOnDispatch(EventMessage message, @Nullable ProcessingContext context, MessageDispatchInterceptorChain<EventMessage> interceptorChain)
MessageStream<?>	MonitoringEventHandlerInterceptor.interceptOnHandle(EventMessage message, ProcessingContext context, MessageHandlerInterceptorChain<EventMessage> interceptorChain)

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

Modifier	Constructor	Description
	MonitoringEventDispatchInterceptor(MessageMonitor<? super EventMessage> messageMonitor)	Constructs a new MonitoringEventDispatchInterceptor using the given MessageMonitor.
	MonitoringEventHandlerInterceptor(MessageMonitor<? super EventMessage> messageMonitor)	Constructs a new MonitoringEventHandlerInterceptor using the given MessageMonitor.

Uses of EventMessage in org.axonframework.modelling

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

Modifier and Type	Method	Description
E	EntityEvolver.evolve(E entity, EventMessage event, ProcessingContext context)	Evolve the given entity by applying the given event to it.
E	PayloadBasedEntityEvolver.evolve(E entity, EventMessage event, ProcessingContext context)
E	SimpleEntityEvolvingComponent.evolve(E entity, EventMessage event, ProcessingContext context)

Uses of EventMessage in org.axonframework.modelling.annotation

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

Modifier and Type	Method	Description
E	AnnotationBasedEntityEvolvingComponent.evolve(E entity, EventMessage event, ProcessingContext context)

Uses of EventMessage in org.axonframework.modelling.entity

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

Modifier and Type	Method	Description
@Nullable E	ConcreteEntityMetamodel.evolve(E entity, EventMessage event, ProcessingContext context)
E	PolymorphicEntityMetamodel.evolve(E entity, EventMessage event, ProcessingContext context)

Uses of EventMessage in org.axonframework.modelling.entity.annotation

Methods in org.axonframework.modelling.entity.annotation with parameters of type EventMessage

Modifier and Type	Method	Description
E	AnnotatedEntityMetamodel.evolve(E entity, EventMessage event, ProcessingContext context)
boolean	RoutingKeyEventTargetMatcher.matches(E childEntity, EventMessage message, ProcessingContext processingContext)

Uses of EventMessage in org.axonframework.modelling.entity.child

Methods in org.axonframework.modelling.entity.child with parameters of type EventMessage

Modifier and Type	Method	Description
P	AbstractEntityChildMetamodel.evolve(P entity, EventMessage event, ProcessingContext context)
boolean	EventTargetMatcher.matches(E targetEntity, EventMessage message, ProcessingContext processingContext)	Tests whether the given entity should be evolved for the given EventMessage.

Uses of EventMessage in org.axonframework.modelling.saga

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

Modifier and Type	Method	Description
protected abstract EventMessage	AbstractSagaManager.withHandlerPayload(EventMessage event, ProcessingContext context)	Returns the given event with its payload converted to the type the Saga's handler declares for it.
protected EventMessage	AnnotatedSagaManager.withHandlerPayload(EventMessage event, ProcessingContext context)

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

Modifier and Type	Method	Description
protected abstract boolean	AbstractSagaManager.canHandle(EventMessage event, ProcessingContext context)	Indicates whether a Saga of the given sagaType has a handler for the given event.
boolean	AnnotatedSaga.canHandle(EventMessage event, ProcessingContext context)
protected boolean	AnnotatedSagaManager.canHandle(EventMessage event, ProcessingContext context)
boolean	Saga.canHandle(EventMessage event, ProcessingContext context)	Indicates whether this saga instance takes the given event, which is the case when it is active and holds the AssociationValue that one of its handlers for this event resolves from it.
protected abstract Set<AssociationValue>	AbstractSagaManager.extractAssociationValues(EventMessage event, ProcessingContext context)	Extracts the AssociationValues from the given event as relevant for a Saga of given sagaType.
protected Set<AssociationValue>	AnnotatedSagaManager.extractAssociationValues(EventMessage event, ProcessingContext context)
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 abstract SagaInitializationPolicy	AbstractSagaManager.getSagaCreationPolicy(EventMessage event, ProcessingContext context)	Returns the Saga Initialization Policy for a Saga of the given sagaType and event.
protected SagaInitializationPolicy	AnnotatedSagaManager.getSagaCreationPolicy(EventMessage event, ProcessingContext context)
MessageStream.Empty<Message>	AbstractSagaManager.handle(EventMessage rawEvent, ProcessingContext context)	Handles the given event within the given context.
MessageStream.Empty<Message>	AnnotatedSaga.handle(EventMessage event, ProcessingContext context)
<T> Object	AssociationResolver.resolve(String associationPropertyName, EventMessage message, MessageHandlingMember<T> handler)	Resolves the associationPropertyName as a value.
<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	PayloadAssociationResolver.resolve(String associationPropertyName, EventMessage message, MessageHandlingMember<T> handler)	Finds the association property value in the message's payload.
Object	AbstractSagaManager.sequenceIdentifierFor(EventMessage event, ProcessingContext context)	Returns the sequence identifier for the given event.
default Object	Saga.sequenceIdentifierFor(EventMessage event, ProcessingContext context)	Returns the sequence identifier for the given event.
protected abstract EventMessage	AbstractSagaManager.withHandlerPayload(EventMessage event, ProcessingContext context)	Returns the given event with its payload converted to the type the Saga's handler declares for it.
protected EventMessage	AnnotatedSagaManager.withHandlerPayload(EventMessage event, ProcessingContext context)

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	Description
List<MessageHandlingMember<? super T>>	SagaModel.findHandlerMethods(EventMessage event, ProcessingContext context)	Returns a List of MessageHandlingMember that can handle the given event.
default boolean	SagaModel.hasHandlerMethod(EventMessage eventMessage, ProcessingContext context)	Indicates whether the Saga described by this model has a handler for the given eventMessage
Optional<AssociationValue>	SagaModel.resolveAssociation(EventMessage eventMessage, ProcessingContext context)	Returns the AssociationValue used to find sagas of type T that can handle the given eventMessage.

Uses of EventMessage in org.axonframework.test.fixture

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

Modifier and Type	Method	Description
MessageStream<EventMessage>	RecordingEventStore.open(StreamingCondition condition, @Nullable ProcessingContext context)
List<EventMessage>	RecordingEventSink.recorded()	Returns a copied list of all the EventMessages published.

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

Modifier and Type	Method	Description
AxonTestPhase.Given	AxonTestPhase.Given.events(EventMessage... messages)	Configures the given messages as events in the "given" state.
T	AxonTestPhase.Then.MessageAssertions.events(EventMessage... expectedEvents)	Expect the given set of event messages to have been published during the AxonTestPhase.When phase.
AxonTestPhase.When.Event	AxonTestPhase.When.events(EventMessage... messages)	Publishes the given Event Messages to the appropriate event handlers and records all activity for result validation.

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

Modifier and Type	Method	Description
T	AxonTestPhase.Then.MessageAssertions.eventsMatch(Predicate<List<EventMessage>> predicate)	Allow to check if the set of event messages which have been published during the When phase match given predicate.
T	AxonTestPhase.Then.MessageAssertions.eventsSatisfy(Consumer<List<EventMessage>> consumer)	Invokes the given consumer of the set of event messages that have been published during the When phase, allowing for any form of assertion.
CompletableFuture<Void>	RecordingEventSink.publish(@Nullable ProcessingContext context, List<? extends EventMessage> events)
Registration	RecordingEventBus.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)
Registration	RecordingEventStore.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)

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	Description
static org.hamcrest.Matcher<List<EventMessage>>	Matchers.noEvents()	Returns a Matcher that matches an empty List of events.

Uses of EventMessage in org.axonframework.test.saga

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

Modifier and Type	Method	Description
FixtureExecutionResult	FixtureExecutionResult.expectNoScheduledEventMatching(Duration durationToScheduledTime, org.hamcrest.Matcher<? super EventMessage> matcher)	Asserts that no event matching the given matcher is scheduled after the given duration.
FixtureExecutionResult	FixtureExecutionResult.expectNoScheduledEventMatching(Instant scheduledTime, org.hamcrest.Matcher<? super EventMessage> matcher)	Asserts that no event matching the given matcher is scheduled at the given scheduledTime.
FixtureExecutionResult	FixtureExecutionResult.expectPublishedEventsMatching(org.hamcrest.Matcher<? extends List<? super EventMessage>> matcher)	Asserts that the Sagas published events matching the given matcher.
FixtureExecutionResult	FixtureExecutionResult.expectScheduledEventMatching(Duration duration, org.hamcrest.Matcher<? super EventMessage> matcher)	Asserts that an event matching the given matcher is scheduled after the given duration.
FixtureExecutionResult	FixtureExecutionResult.expectScheduledEventMatching(Instant scheduledTime, org.hamcrest.Matcher<? super EventMessage> matcher)	Asserts that an event matching the given matcher is scheduled at the given scheduledTime.
FixtureConfiguration	FixtureConfiguration.registerEventHandlerInterceptor(MessageHandlerInterceptor<? super EventMessage> interceptor)	Registers the given interceptor, invoked around the Saga's event handling.
FixtureConfiguration	SagaTestFixture.registerEventHandlerInterceptor(MessageHandlerInterceptor<? super EventMessage> interceptor)