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

Packages that use EventMessage

Package	Description
org.axonframework.axonserver.connector.event	Part of the Axon Server Connector module.
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.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.core.timeout	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.deadletter	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.deadletter.jdbc	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.deadletter.jpa	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	Part of the Axon Messaging module.
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.test.fixture	Part of the Axon Test module.
org.axonframework.test.matchers	Part of the Axon Test module.

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

Methods in org.axonframework.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 org.axonframework.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)
MessageStream<EventMessage>	AxonServerEventStorageEngine.source(SourcingCondition condition)
MessageStream<EventMessage>	AggregateBasedAxonServerEventStorageEngine.stream(StreamingCondition condition)
MessageStream<EventMessage>	AxonServerEventStorageEngine.stream(StreamingCondition condition)

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

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<MessageStream.Entry<EventMessage>>	ContinuousMessageStream.next()
MessageStream<EventMessage>	InterceptingEventStore.open(StreamingCondition condition, @Nullable ProcessingContext context)
MessageStream<EventMessage>	StorageEngineBackedEventStore.open(StreamingCondition condition, @Nullable ProcessingContext context)
Optional<MessageStream.Entry<EventMessage>>	ContinuousMessageStream.peek()
MessageStream<? extends EventMessage>	DefaultEventStoreTransaction.source(SourcingCondition condition)
MessageStream<? extends EventMessage>	DefaultEventStoreTransaction.source(SourcingCondition condition, @Nullable Consumer<Position> resumePositionCallback)
MessageStream<EventMessage>	EventStorageEngine.source(SourcingCondition condition)	Creates a finite MessageStream of events matching the given condition.
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>	EventStorageEngine.stream(StreamingCondition condition)	Creates an infinite MessageStream of events matching the given 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.

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)
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)
MessageStream<EventMessage>	AggregateBasedJpaEventStorageEngine.stream(StreamingCondition condition)

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>,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.core.timeout

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

Modifier and Type	Method	Description
MessageHandlerInterceptor<EventMessage>	UnitOfWorkTimeoutInterceptorBuilder.buildEventInterceptor()	Constructs a EventMessage handler interceptor, to be registered on (e.g.) the EventProcessorConfiguration.

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.
class	TerminalEventMessage	Empty EventMessage implementation without any payload, used as the terminal message of a MessageStream.

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

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

Fields in org.axonframework.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 org.axonframework.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 org.axonframework.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 org.axonframework.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)

Constructor parameters in org.axonframework.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 org.axonframework.messaging.eventhandling.deadletter.jdbc

Classes in org.axonframework.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 org.axonframework.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 org.axonframework.messaging.eventhandling.deadletter.jpa

Classes in org.axonframework.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 org.axonframework.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 org.axonframework.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 org.axonframework.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 org.axonframework.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 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<? extends EventMessage> events, ProcessingContext context)	Processes a batch of events in the 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.

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.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)
boolean	SegmentMatcher.matches(Segment segment, EventMessage event, ProcessingContext context)	Checks whether the given segment matches the given event, based on the configured sequencing policy.
Object	SegmentMatcher.sequenceIdentifier(EventMessage event, ProcessingContext context)	Returns the sequence identifier for the given event, as defined by the configured sequencing policy.
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
	SegmentMatcher(SequencingPolicy<? super EventMessage> sequencingPolicy)	Initialize a SegmentMatcher with the given sequencingPolicy.
	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)	Process the given messages.
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 that return EventMessage

Modifier and Type	Method	Description
EventMessage	DefaultEventBusSpanFactory.propagateContext(EventMessage eventMessage)
EventMessage	EventBusSpanFactory.propagateContext(EventMessage eventMessage)	Propagates the context of the current span to the given event message.

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

Modifier and Type	Method	Description
Span	DefaultEventProcessorSpanFactory.createProcessEventSpan(boolean streaming, EventMessage eventMessage)
Span	EventProcessorSpanFactory.createProcessEventSpan(boolean streaming, EventMessage eventMessage)	Creates a span for the handling of an event.
Span	DefaultEventBusSpanFactory.createPublishEventSpan(EventMessage eventMessage)
Span	EventBusSpanFactory.createPublishEventSpan(EventMessage eventMessage)	Creates a span for the publishing of an event.
MessageStream.Empty<Message>	TracingEventHandlingComponent.handle(EventMessage event, ProcessingContext context)
EventMessage	DefaultEventBusSpanFactory.propagateContext(EventMessage eventMessage)
EventMessage	EventBusSpanFactory.propagateContext(EventMessage eventMessage)	Propagates the context of the current span to the given event message.

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

Modifier and Type	Method	Description
Span	DefaultEventProcessorSpanFactory.createBatchSpan(boolean streaming, List<? extends EventMessage> eventMessages)
Span	EventProcessorSpanFactory.createBatchSpan(boolean streaming, List<? extends EventMessage> eventMessages)	Creates a span for the batch of events that are handled by the event processor.

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

Modifier	Constructor	Description
	TracingEventHandlingComponent(Function<EventMessage,Span> spanProvider, EventHandlingComponent delegate)	Constructs the component with given delegate to receive calls.

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>	MultiStreamableEventSource.open(StreamingCondition condition, @Nullable ProcessingContext context)
MessageStream<EventMessage>	StreamableEventSource.open(StreamingCondition condition, @Nullable ProcessingContext context)	Open an event stream containing all events matching the given condition.

Method parameters in org.axonframework.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 org.axonframework.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 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.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.