Uses of Interface
org.axonframework.messaging.core.Message

Packages that use Message

Package	Description
io.axoniq.framework.messaging.deadletter	Part of the Axon Messaging module.
io.axoniq.framework.messaging.eventhandling.deadletter	Part of the Axon Messaging 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.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	Part of the Axon Extension module.
org.axonframework.extension.reactor.messaging.core.interception	Part of the Axon Extension module.
org.axonframework.extension.spring.authorization	Part of the Axon Extension module.
org.axonframework.extension.spring.config	Part of the Axon Extension module.
org.axonframework.extension.springboot.autoconfig	Part of the Axon Extension module.
org.axonframework.extension.tracing.opentelemetry	Part of the Axon Extension module.
org.axonframework.messaging.commandhandling	Classes that implement the concept of command handling using explicit command objects.
org.axonframework.messaging.commandhandling.gateway	Part of the Axon Messaging module.
org.axonframework.messaging.core	Classes related to message processing in Axon Framework.
org.axonframework.messaging.core.annotation	Part of the Axon Messaging module.
org.axonframework.messaging.core.configuration	Part of the Axon Messaging module.
org.axonframework.messaging.core.conversion	Part of the Axon Messaging module.
org.axonframework.messaging.core.correlation	Part of the Axon Messaging module.
org.axonframework.messaging.core.interception	Part of the Axon Messaging module.
org.axonframework.messaging.core.interception.annotation	Part of the Axon Messaging module.
org.axonframework.messaging.core.retry	Part of the Axon Messaging module.
org.axonframework.messaging.core.sequencing	Part of the Axon Messaging module.
org.axonframework.messaging.core.unitofwork	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.interception	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.processing	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.processing.streaming.segmenting	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.monitoring	Part of the Axon Messaging module.
org.axonframework.messaging.monitoring.configuration	Part of the Axon Messaging module.
org.axonframework.messaging.queryhandling	Package for query handling components in Axon Framework.
org.axonframework.messaging.tracing	Part of the Axon Messaging module.
org.axonframework.messaging.tracing.attributes	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.annotation	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.
org.axonframework.test.util	Part of the Axon Test module.

Uses of Message in io.axoniq.framework.messaging.deadletter

Classes in io.axoniq.framework.messaging.deadletter with type parameters of type Message

Modifier and Type	Interface	Description
interface	DeadLetter<M extends Message>	Interface describing a dead lettered Message implementation of generic type M.
class	DoNotEnqueue<M extends Message>	An EnqueueDecision stating a dead letter should not be enqueued.
interface	EnqueueDecision<M extends Message>	A contract towards describing a decision among a dead letter containing a message of type M concerning whether to add it to a SequencedDeadLetterQueue.
interface	EnqueuePolicy<M extends Message>	A functional interface constructing an EnqueueDecision based on a dead letter and cause.
class	GenericDeadLetter<M extends Message>	Generic implementation of the dead letter allowing any type of Message to be dead lettered.
class	Ignore<M extends Message>	An EnqueueDecision stating a dead letter should be ignored.
class	InMemorySequencedDeadLetterQueue<M extends Message>	In-memory implementation of the SequencedDeadLetterQueue.
static class	InMemorySequencedDeadLetterQueue.Builder<M extends Message>	Builder class to instantiate an InMemorySequencedDeadLetterQueue.
interface	SequencedDeadLetterProcessor<M extends Message>	Contract describing a component that can process dead letters that it has enqueued.
interface	SequencedDeadLetterQueue<M extends Message>	Interface describing the required functionality for a dead letter queue.
class	ShouldEnqueue<M extends Message>	An EnqueueDecision stating a dead letter should be enqueued.

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

Modifier and Type	Method	Description
static <M extends Message> InMemorySequencedDeadLetterQueue.Builder<M>	InMemorySequencedDeadLetterQueue.builder()	Instantiate a builder to construct an InMemorySequencedDeadLetterQueue.
static <M extends Message> InMemorySequencedDeadLetterQueue<M>	InMemorySequencedDeadLetterQueue.defaultQueue()	Construct a default InMemorySequencedDeadLetterQueue.
static <M extends Message> DoNotEnqueue<M>	Decisions.doNotEnqueue()	Construct a DoNotEnqueue defining that a dead letter should not be enqueued at all.
static <M extends Message> ShouldEnqueue<M>	Decisions.enqueue()	Construct a ShouldEnqueue defining that a dead letter should be enqueued.
static <M extends Message> ShouldEnqueue<M>	Decisions.enqueue(Throwable enqueueCause)	Construct a ShouldEnqueue defining that a dead letter should be enqueued because of the given enqueueCause.
static <M extends Message> ShouldEnqueue<M>	Decisions.enqueue(Throwable enqueueCause, Function<DeadLetter<? extends M>,Metadata> diagnosticsBuilder)	Construct a ShouldEnqueue defining that a dead letter should be enqueued because of the given enqueueCause.
static <M extends Message> DoNotEnqueue<M>	Decisions.evict()	Construct a DoNotEnqueue defining that a dead letter should be evicted from the queue.
static <M extends Message> Ignore<M>	Decisions.ignore()	Construct an Ignore defining that a dead letter should remain in the queue.
static <M extends Message> ShouldEnqueue<M>	Decisions.requeue(Throwable requeueCause)	Construct a ShouldEnqueue defining that a dead letter should be requeued because of the given requeueCause.
static <M extends Message> ShouldEnqueue<M>	Decisions.requeue(Throwable requeueCause, Function<DeadLetter<? extends M>,Metadata> diagnosticsBuilder)	Construct a ShouldEnqueue defining that a dead letter should be requeued because of the given requeueCause.

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

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

Modifier and Type	Class	Description
class	CachingSequencedDeadLetterQueue<M extends Message>	A decorator for SequencedDeadLetterQueue that adds per-segment caching of sequence identifiers to optimize CachingSequencedDeadLetterQueue.contains(Object, ProcessingContext) lookups.

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

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

Uses of Message in org.axonframework.eventsourcing.eventstore

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

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.

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

Classes in org.axonframework.extension.metrics.dropwizard with type parameters of type Message

Modifier and Type	Class	Description
class	PayloadTypeMessageMonitorWrapper<T extends MessageMonitor<Message> & io.dropwizard.metrics5.MetricSet>	A MessageMonitor implementation which creates a new MessageMonitor for every Message payload type ingested by it.

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

Modifier and Type	Method	Description
MessageMonitor.MonitorCallback	CapacityMonitor.onMessageIngested(Message message)
MessageMonitor.MonitorCallback	MessageCountingMonitor.onMessageIngested(Message message)
MessageMonitor.MonitorCallback	MessageTimerMonitor.onMessageIngested(Message message)
MessageMonitor.MonitorCallback	PayloadTypeMessageMonitorWrapper.onMessageIngested(Message message)

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

Fields in org.axonframework.extension.metrics.micrometer with type parameters of type Message

Modifier and Type	Field	Description
static final Function<Message,Iterable<io.micrometer.core.instrument.Tag>>	TagsUtil.MESSAGE_TYPE_TAGGER	A function for creating the Micrometer Tag based on the message type name.
static final Function<Message,Iterable<io.micrometer.core.instrument.Tag>>	TagsUtil.METADATA_TAGGER	A function for creating the Micrometer Tags based on the message's metadata.
static final Function<Message,Iterable<io.micrometer.core.instrument.Tag>>	TagsUtil.NO_OP	A function for creating no Micrometer Tags at all.

Methods in org.axonframework.extension.metrics.micrometer that return types with arguments of type Message

Modifier and Type	Method	Description
static Function<Message,Iterable<io.micrometer.core.instrument.Tag>>	TagsUtil.processorNameTag(String processorName)	A function for creating a Micrometer Tag based on the given processorName only, using the TagsUtil.PROCESSOR_NAME_TAG key.
static Function<Message,Iterable<io.micrometer.core.instrument.Tag>>	TagsUtil.processorTags(String processorName)	A function for creating a Micrometer Tags based on the given processorName, using the TagsUtil.PROCESSOR_NAME_TAG key, and the TagsUtil.MESSAGE_TYPE_TAGGER.

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

Modifier and Type	Method	Description
MessageMonitor.MonitorCallback	CapacityMonitor.onMessageIngested(Message message)
MessageMonitor.MonitorCallback	MessageCountingMonitor.onMessageIngested(Message message)
MessageMonitor.MonitorCallback	MessageTimerMonitor.onMessageIngested(Message message)

Method parameters in org.axonframework.extension.metrics.micrometer with type arguments of type Message

Modifier and Type	Method	Description
static CapacityMonitor	CapacityMonitor.buildMonitor(String meterNamePrefix, io.micrometer.core.instrument.MeterRegistry meterRegistry, long window, TimeUnit timeUnit, io.micrometer.core.instrument.Clock clock, Function<Message,Iterable<io.micrometer.core.instrument.Tag>> tagsBuilder)	Creates a capacity monitor with the given time window.
static CapacityMonitor	CapacityMonitor.buildMonitor(String meterNamePrefix, io.micrometer.core.instrument.MeterRegistry meterRegistry, long window, TimeUnit timeUnit, Function<Message,Iterable<io.micrometer.core.instrument.Tag>> tagsBuilder)	Creates a capacity monitor with the default system clock.
static CapacityMonitor	CapacityMonitor.buildMonitor(String meterNamePrefix, io.micrometer.core.instrument.MeterRegistry meterRegistry, Function<Message,Iterable<io.micrometer.core.instrument.Tag>> tagsBuilder)	Creates a capacity monitor with the default time window 10 minutes
static MessageCountingMonitor	MessageCountingMonitor.buildMonitor(String meterNamePrefix, io.micrometer.core.instrument.MeterRegistry meterRegistry, Function<Message,Iterable<io.micrometer.core.instrument.Tag>> tagsBuilder)	Creates a message counting monitor
EventProcessorLatencyMonitor.Builder	EventProcessorLatencyMonitor.Builder.tagsBuilder(Function<Message,Iterable<io.micrometer.core.instrument.Tag>> tagsBuilder)	Configures the Function used to deduce what the Tags should be for a message being monitored.
MessageTimerMonitor.Builder	MessageTimerMonitor.Builder.tagsBuilder(Function<Message,Iterable<io.micrometer.core.instrument.Tag>> tagsBuilder)	Configures the Function used to deduce what the Tags should be for a message being monitored.

Uses of Message in org.axonframework.extension.reactor.messaging.core

Classes in org.axonframework.extension.reactor.messaging.core with type parameters of type Message

Modifier and Type	Interface	Description
interface	ReactorMessageDispatchInterceptor<M extends Message>	Reactor equivalent of MessageDispatchInterceptor.
interface	ReactorMessageDispatchInterceptorChain<M extends Message>	Reactor equivalent of MessageDispatchInterceptorChain.

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

Classes in org.axonframework.extension.reactor.messaging.core.interception with type parameters of type Message

Modifier and Type	Interface	Description
interface	ReactorDispatchInterceptorFactory<M extends Message>	Functional interface for building a ReactorMessageDispatchInterceptor for a specific component type and component name.

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

Modifier and Type	Method	Description
ReactorDispatchInterceptorRegistry	DefaultReactorDispatchInterceptorRegistry.registerInterceptor(ComponentBuilder<ReactorMessageDispatchInterceptor<Message>> interceptorBuilder)
ReactorDispatchInterceptorRegistry	DefaultReactorDispatchInterceptorRegistry.registerInterceptor(ReactorDispatchInterceptorFactory<Message> interceptorFactory)
ReactorDispatchInterceptorRegistry	ReactorDispatchInterceptorRegistry.registerInterceptor(ComponentBuilder<ReactorMessageDispatchInterceptor<Message>> interceptorBuilder)	Registers the given interceptorBuilder for a generic Message ReactorMessageDispatchInterceptor.
ReactorDispatchInterceptorRegistry	ReactorDispatchInterceptorRegistry.registerInterceptor(ReactorDispatchInterceptorFactory<Message> interceptorFactory)	Registers the given component-aware interceptorFactory for a generic Message ReactorMessageDispatchInterceptor.

Uses of Message in org.axonframework.extension.spring.authorization

Classes in org.axonframework.extension.spring.authorization with type parameters of type Message

Modifier and Type	Class	Description
class	MessageAuthorizationDispatchInterceptor<T extends Message>	A MessageDispatchInterceptor that adds the {$code username} and {$code authorities} from the authorized principle.
class	MessageAuthorizationHandlerInterceptor<M extends Message>	A MessageHandlerInterceptor that verifies authorization based on Secured annotations on the payload of Messages.

Uses of Message in org.axonframework.extension.spring.config

Methods in org.axonframework.extension.spring.config that return types with arguments of type Message

Modifier and Type	Method	Description
Class<? extends Message>	MessageHandlerConfigurer.Type.getMessageType()	Returns the supported Message implementation.

Method parameters in org.axonframework.extension.spring.config with type arguments of type Message

Modifier and Type	Method	Description
static List<String>	MessageHandlerLookup.messageHandlerBeans(Class<? extends Message> messageType, org.springframework.beans.factory.config.ConfigurableListableBeanFactory registry)	Returns a list of beans found in the given register that contain a handler for the given messageType.
static List<String>	MessageHandlerLookup.messageHandlerBeans(Class<? extends Message> messageType, org.springframework.beans.factory.config.ConfigurableListableBeanFactory registry, boolean includePrototypeBeans)	Returns a list of beans found in the given register that contain a handler for the given messageType.

Uses of Message in org.axonframework.extension.springboot.autoconfig

Method parameters in org.axonframework.extension.springboot.autoconfig with type arguments of type Message

Modifier and Type	Method	Description
DecoratorDefinition<HandlerInterceptorRegistry,HandlerInterceptorRegistry>	InterceptorAutoConfiguration.handlerInterceptorEnhancer(Optional<List<MessageHandlerInterceptor<Message>>> interceptors, Optional<List<MessageHandlerInterceptor<CommandMessage>>> commandInterceptors, Optional<List<MessageHandlerInterceptor<EventMessage>>> eventInterceptors, Optional<List<MessageHandlerInterceptor<QueryMessage>>> queryInterceptors)	Bean creation method for a DecoratorDefinition that registers Message-specific MessageHandlerInterceptors with the HandlerInterceptorRegistry.

Uses of Message in org.axonframework.extension.tracing.opentelemetry

Methods in org.axonframework.extension.tracing.opentelemetry with type parameters of type Message

Modifier and Type	Method	Description
<M extends Message> M	OpenTelemetrySpanFactory.propagateContext(M message)

Methods in org.axonframework.extension.tracing.opentelemetry with parameters of type Message

Modifier and Type	Method	Description
Span	OpenTelemetrySpanFactory.createDispatchSpan(Supplier<String> operationNameSupplier, Message parentMessage, Message @Nullable ... linkedSiblings)
Span	OpenTelemetrySpanFactory.createHandlerSpan(Supplier<String> operationNameSupplier, Message parentMessage, boolean isChildTrace, Message... linkedParents)
Span	OpenTelemetrySpanFactory.createInternalSpan(Supplier<String> operationNameSupplier, Message message)
@Nullable String	MetadataContextGetter.get(@Nullable Message message, String key)
Iterable<String>	MetadataContextGetter.keys(Message message)

Method parameters in org.axonframework.extension.tracing.opentelemetry with type arguments of type Message

Modifier and Type	Method	Description
OpenTelemetrySpanFactory.Builder	OpenTelemetrySpanFactory.Builder.textMapGetter(io.opentelemetry.context.propagation.TextMapGetter<Message> textMapGetter)	Defines the TextMapGetter to use, which is used for extracting the propagated context from another thread or service.

Uses of Message in org.axonframework.messaging.commandhandling

Subinterfaces of Message in org.axonframework.messaging.commandhandling

Modifier and Type	Interface	Description
interface	CommandMessage	A Message carrying a command as its payload.
interface	CommandResultMessage	A ResultMessage that represents a result from handling a CommandMessage.

Classes in org.axonframework.messaging.commandhandling that implement Message

Modifier and Type	Class	Description
class	GenericCommandMessage	Generic implementation of the CommandMessage interface.
class	GenericCommandResultMessage	Generic implementation of the CommandResultMessage interface.

Constructors in org.axonframework.messaging.commandhandling with parameters of type Message

Modifier	Constructor	Description
	GenericCommandMessage(Message delegate)	Constructs a GenericCommandMessage with given delegate.
	GenericCommandMessage(Message delegate, @Nullable String routingKey, @Nullable Integer priority)	Constructs a GenericCommandMessage with given delegate, routingKey, and priority.
	GenericCommandResultMessage(Message delegate)	Constructs a GenericCommandResultMessage for the given delegate, intended to reconstruct another CommandResultMessage.

Uses of Message in org.axonframework.messaging.commandhandling.gateway

Methods in org.axonframework.messaging.commandhandling.gateway that return types with arguments of type Message

Modifier and Type	Method	Description
CompletableFuture<? extends Message>	CommandResult.getResultMessage()	Returns the result Message within a CompletableFuture of command handling.
CompletableFuture<? extends Message>	FutureCommandResult.getResultMessage()

Method parameters in org.axonframework.messaging.commandhandling.gateway with type arguments of type Message

Modifier and Type	Method	Description
default <R> CommandResult	CommandResult.onSuccess(Class<R> resultType, BiConsumer<R,Message> successHandler)	Attaches the given successHandler to this command result, expecting the given resultType.
default CommandResult	CommandResult.onSuccess(Consumer<Message> successHandler)	Attaches the given successHandler to this command result.

Constructor parameters in org.axonframework.messaging.commandhandling.gateway with type arguments of type Message

Modifier	Constructor	Description
	FutureCommandResult(CompletableFuture<? extends Message> result)	Initializes the CommandResult based on the given result the completes when the result Message becomes available

Uses of Message in org.axonframework.messaging.core

Classes in org.axonframework.messaging.core with type parameters of type Message

Modifier and Type	Class	Description
class	AbstractMessageStream<M extends Message>	Abstract base implementation of MessageStream that provides full state management for consumption, completion, error propagation, closing, and callback coordination.
class	CloseCallbackMessageStream<M extends Message>	MessageStream implementation that invokes the given closeHandler once the stream is closed.
class	DefaultMessageDispatchInterceptorChain<M extends Message>	Default implementation for a MessageDispatchInterceptorChain.
class	DelayedMessageStream<M extends Message>	An implementation of the MessageStream that wraps a stream that will become available asynchronously.
class	DelegatingMessageStream<DM extends Message,RM extends Message>	Abstract implementation of an MessageStream that delegates calls to a given delegate.
class	DelegatingMessageStream<DM extends Message,RM extends Message>	Abstract implementation of an MessageStream that delegates calls to a given delegate.
class	MergedMessageStream<M extends Message>	A MessageStream implementation that merges two underlying message streams into a single stream.
interface	MessageDispatchInterceptor<M extends Message>	Interceptor that allows messages to be intercepted and modified before they are dispatched.
interface	MessageDispatchInterceptorChain<M extends Message>	An interceptor chain that manages the flow of a Message of type M through a chain of interceptors.
interface	MessageHandlerInterceptor<M extends Message>	Workflow interface that allows for customized message handler invocation chains.
interface	MessageHandlerInterceptorChain<M extends Message>	An interceptor chain that manages the flow of a Message of type M through a chain of interceptors, and ultimately to a message handler.
interface	MessageStream<M extends Message>	Represents a stream of entries containing Messages of type M that can be consumed as they become available.
static interface	MessageStream.Empty<M extends Message>	A MessageStream implementation that completes normally or with an error without returning any elements.
static interface	MessageStream.Entry<M extends Message>	A MessageStream-specific container of Message implementations.
static interface	MessageStream.Single<M extends Message>	A MessageStream implementation that returns at most a single result before completing.
class	QueueMessageStream<M extends Message>	A MessageStream implementation backed by a BlockingQueue.
final record	SimpleEntry<M extends Message>	Simple implementation of the MessageStream.Entry containing a single Message implementation of type M and a Context.

Subinterfaces of Message in org.axonframework.messaging.core

Modifier and Type	Interface	Description
interface	ResultMessage	A Message that represents a result of handling some form of a request message.

Classes in org.axonframework.messaging.core that implement Message

Modifier and Type	Class	Description
class	AbstractMessage	Abstract base class for Messages.
class	GenericMessage	Generic implementation of the Message interface containing the payload and metadata in deserialized form.
class	GenericResultMessage	Generic implementation of ResultMessage interface.
class	MessageDecorator	Abstract implementation of a Message that delegates to an existing message.

Fields in org.axonframework.messaging.core with type parameters of type Message

Modifier and Type	Field	Description
static final Context.ResourceKey<Message>	Message.RESOURCE_KEY	The Context.ResourceKey used to store and retrieve the Message from the ProcessingContext.

Methods in org.axonframework.messaging.core with type parameters of type Message

Modifier and Type	Method	Description
static <M extends Message> MessageStream<M>	FluxUtils.asMessageStream(reactor.core.publisher.Flux<M> flux)	Create a stream that provides the Messages returned by the given flux, automatically wrapped in an MessageStream.Entry.
static <M extends Message> MessageStream<M>	FluxUtils.asMessageStream(reactor.core.publisher.Flux<M> flux, Function<M,Context> contextSupplier)	Create a stream that provides the Messages returned by the given flux, automatically wrapped in an MessageStream.Entry with the resulting Context from the contextSupplier.
static <M extends Message> MessageStream.Single<M>	MonoUtils.asSingle(reactor.core.publisher.Mono<M> mono)	Create a stream that returns a single entry wrapping the Message from the given mono, once the given mono completes.
static <M extends Message> MessageStream.Single<M>	MonoUtils.asSingle(reactor.core.publisher.Mono<M> mono, Function<M,Context> contextSupplier)	Create a stream that returns a single entry wrapping the Message from the given mono, once the given mono completes.
default <T extends Message> MessageStream<T>	MessageStream.cast()	Casts this stream to the given type.
default <T extends Message> MessageStream.Empty<T>	MessageStream.Empty.cast()
default <R extends Message> MessageStream.Single<R>	MessageStream.Single.cast()
static <M extends Message> MessageStream<M>	DelayedMessageStream.create(CompletableFuture<? extends MessageStream<M>> delegate)	Creates a stream that delays actions to its delegate when it becomes available.
static <M extends Message> MessageStream.Single<M>	DelayedMessageStream.createSingle(CompletableFuture<MessageStream.Single<M>> delegate)	Creates a single stream that delays actions to its delegate when it becomes available.
static <M extends Message> MessageStream.Empty<M>	MessageStream.empty()	Create a stream that carries no MessageStream.Entry and is considered to be successfully completed.
static <M extends Message> MessageStream.Empty<M>	MessageStream.failed(Throwable failure)	Create a stream that completed with given failure.
static <M extends Message> MessageStream.Single<M>	MessageStream.fromFuture(CompletableFuture<? extends @Nullable M> future)	Create a stream that returns a single entry wrapping the Message from the given future, once the given future completes.
static <M extends Message> MessageStream.Single<M>	MessageStream.fromFuture(CompletableFuture<? extends @Nullable M> future, Function<M,Context> contextSupplier)	Create a stream that returns a single entry wrapping the Message from the given future, once the given future completes.
static <M extends Message> MessageStream<M>	MessageStream.fromItems(M... items)	Creates a MessageStream that provides the given items and then completes.
static <M extends Message> MessageStream<M>	MessageStream.fromIterable(Iterable<? extends M> iterable)	Create a stream that provides the Messages returned by the given iterable, automatically wrapped in an MessageStream.Entry.
static <M extends Message> MessageStream<M>	MessageStream.fromIterable(Iterable<? extends M> iterable, Function<? super M,? extends Context> contextSupplier)	Create a stream that provides the Messages returned by the given iterable, automatically wrapped in an MessageStream.Entry with the resulting Context from the contextSupplier.
static <M extends Message> MessageStream<M>	MessageStream.fromStream(Stream<? extends M> stream)	Create a stream that provides the Messages returned by the given stream, automatically wrapped in an MessageStream.Entry.
static <M extends Message> MessageStream<M>	MessageStream.fromStream(Stream<? extends M> stream, Function<? super M,? extends Context> contextSupplier)	Create a stream that provides the Messages returned by the given stream, automatically wrapped in an MessageStream.Entry with the resulting Context from the contextSupplier.
static <T, M extends Message> MessageStream<M>	MessageStream.fromStream(Stream<? extends T> stream, Function<? super T,? extends M> messageSupplier, Function<? super T,? extends Context> contextSupplier)	Create a stream that provides the items of type T returned by the given stream, automatically wrapped in an MessageStream.Entry with the resulting Message and Context from the messageSupplier and the contextSupplier respectively.
static <M extends Message> MessageStream.Single<M>	MessageStream.just(@Nullable M message)	Create a stream containing the single given message, automatically wrapped in an MessageStream.Entry.
static <M extends Message> MessageStream.Single<M>	MessageStream.just(@Nullable M message, Function<M,Context> contextSupplier)	Create a stream containing the single given message, automatically wrapped in an MessageStream.Entry.
default <RM extends Message> MessageStream.Empty<RM>	MessageStream.Empty.map(Function<MessageStream.Entry<M>,MessageStream.Entry<RM>> mapper)
<RM extends Message> MessageStream.Entry<RM>	MessageStream.Entry.map(Function<M,RM> mapper)	Maps the MessageStream.Entry.message() by running it through the given mapper.
default <RM extends Message> MessageStream<RM>	MessageStream.map(Function<MessageStream.Entry<M>,MessageStream.Entry<RM>> mapper)	Returns a stream that maps each entry from this stream using given mapper function into an entry carrying a MessageEntry with a Message of type RM.
default <RM extends Message> MessageStream.Single<RM>	MessageStream.Single.map(Function<MessageStream.Entry<M>,MessageStream.Entry<RM>> mapper)
<RM extends Message> MessageStream.Entry<RM>	SimpleEntry.map(Function<M,RM> mapper)
default <RM extends Message> MessageStream.Empty<RM>	MessageStream.Empty.mapMessage(Function<M,RM> mapper)
default <RM extends Message> MessageStream<RM>	MessageStream.mapMessage(Function<M,RM> mapper)	Returns a stream that maps each message from the entries in this stream using the given mapper function.
default <RM extends Message> MessageStream.Single<RM>	MessageStream.Single.mapMessage(Function<M,RM> mapper)
static <M extends Message> AbstractMessageStream.FetchResult<MessageStream.Entry<M>>	AbstractMessageStream.FetchResult.of(MessageStream<M> delegate)	Creates a FetchResult reflecting the current observable state of the given MessageStream.
static <M extends Message> reactor.core.publisher.Flux<MessageStream.Entry<M>>	FluxUtils.of(MessageStream<? extends M> source)	Creates a Flux containing the entries provided by the given source.
static <M extends Message, R> CompletableFuture<@Nullable R>	MessageStreamUtils.reduce(MessageStream<M> source, @Nullable R identity, BiFunction<@Nullable R,? super MessageStream.Entry<M>,@Nullable R> accumulator)	Returns a CompletableFuture that completes with the given reduction of messages read from the source.
static <M extends Message> org.reactivestreams.Publisher<M>	FluxUtils.streamToPublisher(Supplier<MessageStream<M>> stream)	Converts a Supplier of MessageStream into a reactor-core Publisher.

Methods in org.axonframework.messaging.core that return Message

Modifier and Type	Method	Description
Message	AbstractMessage.andMetadata(Map<String,@Nullable String> metadata)
Message	Message.andMetadata(Map<String,@Nullable String> metadata)	Returns a copy of this Message (implementation) with its metadata merged with the given metadata.
protected Message	MessageDecorator.delegate()	Returns the wrapped Message delegated by this decorator.
static Message	GenericMessage.emptyMessage()	Construct an empty message.
static @Nullable Message	Message.fromContext(ProcessingContext context)	Retrieves the Message from the given context using the RESOURCE_KEY.
Message	GenericMessage.withConvertedPayload(Type type, Converter converter)
default Message	Message.withConvertedPayload(Class<?> type, Converter converter)	Returns a new Message implementation with its payload() converted to the given type by the given converter.
Message	Message.withConvertedPayload(Type type, Converter converter)	Returns a new Message implementation with its payload() converted to the given type by the given converter.
default Message	Message.withConvertedPayload(TypeReference<?> type, Converter converter)	Returns a new Message implementation with its payload() converted to the given type by the given converter.
Message	MessageDecorator.withConvertedPayload(Type type, Converter converter)
Message	AbstractMessage.withMetadata(Map<String,String> metadata)
protected abstract Message	AbstractMessage.withMetadata(Metadata metadata)	Returns a new message instance with the same payload and properties as this message but given metadata.
protected Message	GenericMessage.withMetadata(Metadata metadata)
Message	Message.withMetadata(Map<String,String> metadata)	Returns a copy of this Message (implementation) with the given metadata.

Methods in org.axonframework.messaging.core with parameters of type Message

Modifier and Type	Method	Description
static ProcessingContext	Message.addToContext(ProcessingContext context, Message message)	Adds the given message to the given context under the RESOURCE_KEY.
static <M extends Message> MessageStream<M>	MessageStream.fromItems(M... items)	Creates a MessageStream that provides the given items and then completes.

Constructors in org.axonframework.messaging.core with parameters of type Message

Modifier	Constructor	Description
	GenericResultMessage(Message delegate)	Constructs a GenericResultMessage for the given delegate, intended to reconstruct another ResultMessage.
protected	MessageDecorator(Message delegate)	Initializes a new decorator with given delegate Message.

Uses of Message in org.axonframework.messaging.core.annotation

Methods in org.axonframework.messaging.core.annotation with type parameters of type Message

Modifier and Type	Method	Description
static <M extends Message> MessageStream<?>	InterceptorChainParameterResolverFactory.callWithInterceptorChain(ProcessingContext processingContext, MessageHandlerInterceptorChain<M> interceptorChain, Function<ProcessingContext,MessageStream<?>> action)	Invoke the given action with the given interceptorChain being available for parameter injection.
static <M extends Message> MessageHandlerInterceptorChain<M>	InterceptorChainParameterResolverFactory.currentInterceptorChain(ProcessingContext processingContext)

Methods in org.axonframework.messaging.core.annotation with parameters of type Message

Modifier and Type	Method	Description
boolean	MessageHandlingMember.canHandle(Message message, ProcessingContext context)	Checks if this handler is capable of handling the given message.
boolean	MethodInvokingMessageHandlingMember.canHandle(Message message, ProcessingContext context)
boolean	WrappedMessageHandlingMember.canHandle(Message message, ProcessingContext context)
MessageStream<?>	ChainedMessageHandlerInterceptorMember.handle(Message message, ProcessingContext context, T target, MessageHandlingMember<? super T> handler)
MessageStream<?>	MessageHandlingMember.handle(Message message, ProcessingContext context, @Nullable T target)	Handles the given message within the given context by invoking the appropriate method on given target.
MessageStream<?>	MethodInvokingMessageHandlingMember.handle(Message message, ProcessingContext context, @Nullable T target)
MessageStream<?>	WrappedMessageHandlingMember.handle(Message message, ProcessingContext context, @Nullable T target)
Object	ChainedMessageHandlerInterceptorMember.handleSync(Message message, ProcessingContext context, T target, MessageHandlingMember<? super T> handler)
Object	MessageHandlingMember.handleSync(Message message, ProcessingContext context, @Nullable T target)	Deprecated, for removal: This API element is subject to removal in a future version. In favor of MessageHandlingMember.handle(Message, ProcessingContext, Object).
Object	MethodInvokingMessageHandlingMember.handleSync(Message message, ProcessingContext context, @Nullable T target)
Object	WrappedMessageHandlingMember.handleSync(Message message, ProcessingContext context, @Nullable T target)
protected boolean	MethodInvokingMessageHandlingMember.parametersMatch(Message message, ProcessingContext processingContext)	Checks if the parameter resolvers of this member are compatible with the given message.
protected boolean	MethodInvokingMessageHandlingMember.typeMatches(Message message)	Checks if this member can handle the type of the given message.

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

Modifier and Type	Method	Description
boolean	MessageHandlingMember.canHandleMessageType(Class<? extends Message> messageType)	Checks if this handler is capable of handling Message implementations of the given messageType.
boolean	MethodInvokingMessageHandlingMember.canHandleMessageType(Class<? extends Message> messageType)
boolean	WrappedMessageHandlingMember.canHandleMessageType(Class<? extends Message> messageType)

Constructor parameters in org.axonframework.messaging.core.annotation with type arguments of type Message

Modifier	Constructor	Description
	MethodInvokingMessageHandlingMember(Method method, Class<? extends Message> messageType, Class<?> explicitPayloadType, ParameterResolverFactory parameterResolverFactory, Function<Object,MessageStream<?>> returnTypeConverter)	Initializes a new instance that will invoke the given executable (method) on a target to handle a message of the given messageType.

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

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

Modifier and Type	Method	Description
MessagingConfigurer	MessagingConfigurer.registerDispatchInterceptor(ComponentBuilder<MessageDispatchInterceptor<Message>> interceptorBuilder)	Registers the given generic Message MessageDispatchInterceptor builder in this Configurer.
MessagingConfigurer	MessagingConfigurer.registerMessageHandlerInterceptor(ComponentBuilder<MessageHandlerInterceptor<Message>> interceptorBuilder)	Registers the given generic Message MessageHandlerInterceptor builder in this Configurer.
MessagingConfigurer	MessagingConfigurer.registerMessageMonitor(ComponentBuilder<MessageMonitor<Message>> monitorBuilder)	Registers a MessageMonitor builder for any type of messaging component in this configuration.
MessagingConfigurer	MessagingConfigurer.registerMessageMonitor(MessageMonitorFactory<Message> monitorFactory)	Registers a message monitor factory for any type of messaging component in this configuration.

Uses of Message in org.axonframework.messaging.core.conversion

Methods in org.axonframework.messaging.core.conversion with type parameters of type Message

Modifier and Type	Method	Description
<M extends Message> M	DelegatingMessageConverter.convertMessage(M message, Type targetType)
default <M extends Message, T> M	MessageConverter.convertMessage(M message, Class<T> targetType)	Converts the given message's payload to the given targetType, returning a new Message with the converted payload.
<M extends Message> M	MessageConverter.convertMessage(M message, Type targetType)	Converts the given message's payload to the given targetType, returning a new Message with the converted payload.
<M extends Message, T> @Nullable T	DelegatingMessageConverter.convertPayload(M message, Type targetType)
default <M extends Message, T> @Nullable T	MessageConverter.convertPayload(M message, Class<T> targetType)	Converts the given message's payload into a payload of the given targetType.
<M extends Message, T> @Nullable T	MessageConverter.convertPayload(M message, Type targetType)	Converts the given message's payload into a payload of the given targetType.

Uses of Message in org.axonframework.messaging.core.correlation

Methods in org.axonframework.messaging.core.correlation with parameters of type Message

Modifier and Type	Method	Description
Map<String,String>	CorrelationDataProvider.correlationDataFor(Message message)	Provides a map with the entries to attach as correlation data to generated messages while processing given message.
Map<String,String>	MessageOriginProvider.correlationDataFor(Message message)
Map<String,String>	MultiCorrelationDataProvider.correlationDataFor(Message message)
Map<String,String>	SimpleCorrelationDataProvider.correlationDataFor(Message message)

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

Classes in org.axonframework.messaging.core.interception with type parameters of type Message

Modifier and Type	Class	Description
class	BeanValidationInterceptor<M extends Message>	Interceptor that applies JSR303 bean validation on incoming Messages.
class	CorrelationDataInterceptor<M extends Message>	A MessageDispatchInterceptor and MessageHandlerInterceptor implementation using CorrelationDataProviders to collect and set a collection of correlation data.
interface	DispatchInterceptorFactory<M extends Message>	Functional interface for building a MessageDispatchInterceptor for a specific component type and component name.
interface	HandlerInterceptorFactory<M extends Message>	Functional interface for building a MessageHandlerInterceptor for a specific component type and component name.
class	LoggingInterceptor<M extends Message>	A MessageDispatchInterceptor and MessageHandlerInterceptor implementation that logs dispatched and incoming messages, and their result, to a Logger.

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

Modifier and Type	Method	Description
DispatchInterceptorRegistry	DefaultDispatchInterceptorRegistry.registerInterceptor(ComponentBuilder<MessageDispatchInterceptor<Message>> interceptorBuilder)
DispatchInterceptorRegistry	DefaultDispatchInterceptorRegistry.registerInterceptor(DispatchInterceptorFactory<Message> interceptorFactory)
HandlerInterceptorRegistry	DefaultHandlerInterceptorRegistry.registerInterceptor(ComponentBuilder<MessageHandlerInterceptor<Message>> interceptorBuilder)
HandlerInterceptorRegistry	DefaultHandlerInterceptorRegistry.registerInterceptor(HandlerInterceptorFactory<Message> interceptorFactory)
DispatchInterceptorRegistry	DispatchInterceptorRegistry.registerInterceptor(ComponentBuilder<MessageDispatchInterceptor<Message>> interceptorBuilder)	Registers the given interceptorBuilder for a generic Message MessageDispatchInterceptor.
DispatchInterceptorRegistry	DispatchInterceptorRegistry.registerInterceptor(DispatchInterceptorFactory<Message> interceptorFactory)	Registers the given component-aware interceptorFactory for a generic Message MessageDispatchInterceptor.
HandlerInterceptorRegistry	HandlerInterceptorRegistry.registerInterceptor(ComponentBuilder<MessageHandlerInterceptor<Message>> interceptorBuilder)	Registers the given interceptorBuilder constructing a generic Message MessageHandlerInterceptor for all handling infrastructure components.
HandlerInterceptorRegistry	HandlerInterceptorRegistry.registerInterceptor(HandlerInterceptorFactory<Message> interceptorFactory)	Registers the given component-aware interceptorFactory constructing a generic Message MessageHandlerInterceptor for all handling infrastructure components.

Uses of Message in org.axonframework.messaging.core.interception.annotation

Methods in org.axonframework.messaging.core.interception.annotation with parameters of type Message

Modifier and Type	Method	Description
default MessageStream<?>	MessageHandlerInterceptorMemberChain.handle(Message message, ProcessingContext context, T target, MessageHandlingMember<? super T> handler)
MessageStream<?>	NoMoreInterceptors.handle(Message message, ProcessingContext context, T target, MessageHandlingMember<? super T> handler)
Object	MessageHandlerInterceptorMemberChain.handleSync(Message message, ProcessingContext context, T target, MessageHandlingMember<? super T> handler)	Deprecated, for removal: This API element is subject to removal in a future version.
default Object	MessageHandlerInterceptorMemberChain.handleSync(Message message, T target, MessageHandlingMember<? super T> handler)	Deprecated, for removal: This API element is subject to removal in a future version.
Object	NoMoreInterceptors.handleSync(Message message, ProcessingContext context, T target, MessageHandlingMember<? super T> handler)	Deprecated.

Uses of Message in org.axonframework.messaging.core.retry

Classes in org.axonframework.messaging.core.retry with type parameters of type Message

Modifier and Type	Interface	Description
static interface	RetryScheduler.Dispatcher<M extends Message,R extends Message>	Represents the logic to dispatch a message and attempt to retrieve the result
static interface	RetryScheduler.Dispatcher<M extends Message,R extends Message>	Represents the logic to dispatch a message and attempt to retrieve the result

Methods in org.axonframework.messaging.core.retry with type parameters of type Message

Modifier and Type	Method	Description
<M extends Message, R extends Message> MessageStream<R>	AsyncRetryScheduler.scheduleRetry(M message, @Nullable ProcessingContext processingContext, Throwable cause, RetryScheduler.Dispatcher<M,R> dispatcher)
<M extends Message, R extends Message> MessageStream<R>	AsyncRetryScheduler.scheduleRetry(M message, @Nullable ProcessingContext processingContext, Throwable cause, RetryScheduler.Dispatcher<M,R> dispatcher)
<M extends Message, R extends Message> MessageStream<R>	RetryScheduler.scheduleRetry(M message, @Nullable ProcessingContext processingContext, Throwable cause, RetryScheduler.Dispatcher<M,R> dispatcher)	Schedules the given message to retry dispatching using the given dispatching function.
<M extends Message, R extends Message> MessageStream<R>	RetryScheduler.scheduleRetry(M message, @Nullable ProcessingContext processingContext, Throwable cause, RetryScheduler.Dispatcher<M,R> dispatcher)	Schedules the given message to retry dispatching using the given dispatching function.

Methods in org.axonframework.messaging.core.retry with parameters of type Message

Modifier and Type	Method	Description
RetryPolicy.Outcome	ExponentialBackOffRetryPolicy.defineFor(Message message, Throwable failure, List<Class<? extends Throwable>[]> previousFailures)
RetryPolicy.Outcome	FilteringRetryPolicy.defineFor(Message message, Throwable cause, List<Class<? extends Throwable>[]> previousFailures)
RetryPolicy.Outcome	MaxAttemptsPolicy.defineFor(Message message, Throwable cause, List<Class<? extends Throwable>[]> previousFailures)
RetryPolicy.Outcome	RetryPolicy.defineFor(Message message, Throwable failure, List<Class<? extends Throwable>[]> previousFailures)	Provides the outcome for the policy given the failed message that was dispatched and resulted in given failure.

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

Classes in org.axonframework.messaging.core.sequencing with type parameters of type Message

Modifier and Type	Class	Description
class	FallbackSequencingPolicy<E extends Exception,M extends Message>	Implementation of SequencingPolicy that provides exception-based fallback behavior.
class	HierarchicalSequencingPolicy<M extends Message>	Implementation of SequencingPolicy that combines two policies in a fallback pattern.
interface	SequencingPolicy<M extends Message>	Interface to a policy definition for concurrent message processing.

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

Modifier and Type	Method	Description
Optional<Object>	ExtractionSequencingPolicy.sequenceIdentifierFor(Message message, ProcessingContext context)
Optional<Object>	FullConcurrencyPolicy.sequenceIdentifierFor(Message message, ProcessingContext context)
Optional<Object>	MetadataSequencingPolicy.sequenceIdentifierFor(Message message, ProcessingContext context)
Optional<Object>	NoOpSequencingPolicy.sequenceIdentifierFor(@NonNull Message message, @NonNull ProcessingContext context)
Optional<Object>	SequentialPolicy.sequenceIdentifierFor(Message message, ProcessingContext context)

Uses of Message in org.axonframework.messaging.core.unitofwork

Constructors in org.axonframework.messaging.core.unitofwork with parameters of type Message

Modifier	Constructor	Description
	LegacyMessageSupportingContext(Message message)	Deprecated. Initialize the ProcessingContext with the given message as the only resource.

Uses of Message in org.axonframework.messaging.eventhandling

Subinterfaces of Message in org.axonframework.messaging.eventhandling

Modifier and Type	Interface	Description
interface	EventMessage	A Message wrapping an event, which is represented by its payload.

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

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

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

Modifier and Type	Method	Description
MessageStream.Empty<Message>	DelegatingEventHandlingComponent.handle(EventMessage event, ProcessingContext context)
MessageStream.Empty<Message>	DelegatingEventHandlingComponent.handle(ReplayStatusChanged statusChange, ProcessingContext context)
MessageStream.Empty<Message>	DelegatingEventHandlingComponent.handle(ResetContext resetContext, ProcessingContext context)
MessageStream.Empty<Message>	EventHandler.handle(EventMessage event, ProcessingContext context)	Handles the given event within the given context.
default MessageStream.Empty<Message>	EventHandlingComponent.handle(ReplayStatusChanged statusChange, ProcessingContext context)
default MessageStream.Empty<Message>	EventHandlingComponent.handle(ResetContext resetContext, ProcessingContext context)
MessageStream.Empty<Message>	SimpleEventHandlingComponent.handle(EventMessage event, ProcessingContext context)
MessageStream.Empty<Message>	SimpleEventHandlingComponent.handle(ReplayStatusChanged statusChange, ProcessingContext context)
MessageStream.Empty<Message>	SimpleEventHandlingComponent.handle(ResetContext resetContext, ProcessingContext context)

Constructors in org.axonframework.messaging.eventhandling with parameters of type Message

Modifier	Constructor	Description
protected	GenericEventMessage(Message delegate, Instant timestamp)	Constructs a GenericEventMessage with given delegate and timestamp.
	GenericEventMessage(Message delegate, Supplier<Instant> timestampSupplier)	Constructs a GenericEventMessage for the given delegate and timestampSupplier, intended to reconstruct another EventMessage.

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

Methods in org.axonframework.messaging.eventhandling.annotation that return types with arguments of type Message

Modifier and Type	Method	Description
MessageStream.Empty<Message>	AnnotatedEventHandlingComponent.handle(EventMessage event, ProcessingContext context)
MessageStream.Empty<Message>	AnnotatedEventHandlingComponent.handle(ReplayStatusChanged statusChange, ProcessingContext context)
MessageStream.Empty<Message>	AnnotatedEventHandlingComponent.handle(ResetContext resetContext, ProcessingContext context)

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

Methods in org.axonframework.messaging.eventhandling.interception that return types with arguments of type Message

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

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

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

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 Message in org.axonframework.messaging.eventhandling.processing.streaming.segmenting

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

Modifier and Type	Method	Description
MessageStream.Empty<Message>	SequenceOverridingEventHandlingComponent.handle(EventMessage event, ProcessingContext context)
MessageStream.Empty<Message>	SequenceOverridingEventHandlingComponent.handle(ReplayStatusChanged statusChange, ProcessingContext context)
MessageStream.Empty<Message>	SequenceOverridingEventHandlingComponent.handle(ResetContext resetContext, ProcessingContext context)
MessageStream.Empty<Message>	SequencingEventHandlingComponent.handle(EventMessage event, ProcessingContext context)

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

Subinterfaces of Message in org.axonframework.messaging.eventhandling.replay

Modifier and Type	Interface	Description
interface	ReplayStatusChanged	A Message signalling that the ReplayStatus of an Event Handling Component changed.
interface	ResetContext	A Message initiating the reset of an Event Handling Component.

Classes in org.axonframework.messaging.eventhandling.replay that implement Message

Modifier and Type	Class	Description
class	GenericReplayStatusChanged	Generic implementation of the ReplayStatusChanged interface.
class	GenericResetContext	Generic implementation of the ResetContext interface.

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

Modifier and Type	Method	Description
MessageStream.Empty<Message>	ReplayBlockingEventHandlingComponent.handle(EventMessage event, ProcessingContext context)	Handles the given event unless a replay is in progress.
MessageStream.Empty<Message>	ReplayStatusChangedHandler.handle(ReplayStatusChanged statusChange, ProcessingContext context)	Handles the given ReplayStatusChanged message, allowing for tasks to be performed when the replay starts and ends.
MessageStream.Empty<Message>	ResetHandler.handle(ResetContext resetContext, ProcessingContext context)	Handles the given ResetContext message, performing any necessary reset operations.

Constructors in org.axonframework.messaging.eventhandling.replay with parameters of type Message

Modifier	Constructor	Description
	GenericReplayStatusChanged(ReplayStatus status, Message delegate)	Constructs a GenericReplayStatusChange for the given delegate, intended to reconstruct another ReplayStatusChanged.
	GenericResetContext(Message delegate)	Constructs a GenericResetContext for the given delegate, intended to reconstruct another ResetContext.

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

Methods in org.axonframework.messaging.eventhandling.tracing that return types with arguments of type Message

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

Uses of Message in org.axonframework.messaging.monitoring

Classes in org.axonframework.messaging.monitoring with type parameters of type Message

Modifier and Type	Interface	Description
interface	MessageMonitor<T extends Message>	Specifies a mechanism to monitor message processing.
class	MultiMessageMonitor<T extends Message>	Delegates messages and callbacks to the given list of message monitors

Methods in org.axonframework.messaging.monitoring with parameters of type Message

Modifier and Type	Method	Description
MessageMonitor.MonitorCallback	NoOpMessageMonitor.onMessageIngested(Message message)

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

Classes in org.axonframework.messaging.monitoring.configuration with type parameters of type Message

Modifier and Type	Interface	Description
interface	MessageMonitorFactory<M extends Message>	Functional interface for building a MessageMonitor for a specific component type and component name.

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

Modifier and Type	Method	Description
MessageMonitorRegistry	DefaultMessageMonitorRegistry.registerMonitor(ComponentBuilder<MessageMonitor<Message>> monitorBuilder)
MessageMonitorRegistry	DefaultMessageMonitorRegistry.registerMonitor(MessageMonitorFactory<Message> monitorFactory)
MessageMonitorRegistry	MessageMonitorRegistry.registerMonitor(ComponentBuilder<MessageMonitor<Message>> monitorBuilder)	Registers a MessageMonitor for generic Message types using the supplied monitor builder.
MessageMonitorRegistry	MessageMonitorRegistry.registerMonitor(MessageMonitorFactory<Message> monitorFactory)	Registers a component-aware MessageMonitor for generic Message types using the given monitorFactory.

Uses of Message in org.axonframework.messaging.queryhandling

Subinterfaces of Message in org.axonframework.messaging.queryhandling

Modifier and Type	Interface	Description
interface	QueryMessage	A Message type that carries a Query: a request for information.
interface	QueryResponseMessage	A ResultMessage implementation that contains the result of query handling.
interface	SubscriptionQueryUpdateMessage	A ResultMessage implementation that holds incremental update of a subscription query.

Classes in org.axonframework.messaging.queryhandling that implement Message

Modifier and Type	Class	Description
class	GenericQueryMessage	Generic implementation of the QueryMessage interface.
class	GenericQueryResponseMessage	Generic implementation of the QueryResponseMessage interface.
class	GenericSubscriptionQueryUpdateMessage	Generic implementation of the SubscriptionQueryUpdateMessage interface holding incremental update of a subscription query.

Constructors in org.axonframework.messaging.queryhandling with parameters of type Message

Modifier	Constructor	Description
	GenericQueryMessage(Message delegate)	Constructs a GenericQueryMessage with given delegate and responseType.
	GenericQueryMessage(Message delegate, @Nullable Integer priority)	Constructs a GenericQueryMessage with given delegate, responseType and priority.
	GenericQueryResponseMessage(Message delegate)	Constructs a GenericQueryResponseMessage for the given delegate, intended to reconstruct another QueryResponseMessage.
	GenericSubscriptionQueryUpdateMessage(Message delegate)	Initializes a new decorator with given delegate message.

Uses of Message in org.axonframework.messaging.tracing

Methods in org.axonframework.messaging.tracing with type parameters of type Message

Modifier and Type	Method	Description
<M extends Message> M	MultiSpanFactory.propagateContext(M message)
<M extends Message> M	NoOpSpanFactory.propagateContext(M message)
<M extends Message> M	SpanFactory.propagateContext(M message)	Propagates the currently active trace and span to the message.

Methods in org.axonframework.messaging.tracing with parameters of type Message

Modifier and Type	Method	Description
default Span	SpanFactory.createChildHandlerSpan(Supplier<String> operationNameSupplier, Message parentMessage, Message... linkedParents)	Creates a new Span which is part of the current trace.
Span	MultiSpanFactory.createDispatchSpan(Supplier<String> operationNameSupplier, Message parentMessage, Message @Nullable ... linkedSiblings)
Span	NoOpSpanFactory.createDispatchSpan(Supplier<String> operationNameSupplier, Message parentMessage, Message @Nullable ... linkedSiblings)
Span	SpanFactory.createDispatchSpan(Supplier<String> operationNameSupplier, Message parentMessage, Message @Nullable ... linkedSiblings)	Creates a new Span linked to dispatching a Message, for example when sending a command to Axon Server.
Span	MultiSpanFactory.createHandlerSpan(Supplier<String> operationNameSupplier, Message parentMessage, boolean isChildTrace, Message @Nullable ... linkedParents)
Span	NoOpSpanFactory.createHandlerSpan(Supplier<String> operationNameSupplier, Message parentMessage, boolean isChildTrace, Message @Nullable ... linkedParents)
Span	SpanFactory.createHandlerSpan(Supplier<String> operationNameSupplier, Message parentMessage, boolean isChildTrace, Message @Nullable ... linkedParents)	Creates a new Span linked to asynchronously handling a Message, for example when handling a command from Axon Server.
Span	MultiSpanFactory.createInternalSpan(Supplier<String> operationNameSupplier, Message message)
Span	NoOpSpanFactory.createInternalSpan(Supplier<String> operationNameSupplier, Message message)
Span	SpanFactory.createInternalSpan(Supplier<String> operationNameSupplier, Message message)	Creates a new Span linked to the currently active span.
default Span	SpanFactory.createLinkedHandlerSpan(Supplier<String> operationNameSupplier, Message parentMessage, Message... linkedParents)	Creates a new Span which becomes its own separate trace, linked to the previous span.
static String	SpanUtils.determineMessageName(Message message)	Creates a human-readable name for a message based on its type().
Map<String,String>	SpanAttributesProvider.provideForMessage(Message message)	Provides a map of attributes to add to the Span based on the Message provided.

Uses of Message in org.axonframework.messaging.tracing.attributes

Methods in org.axonframework.messaging.tracing.attributes with parameters of type Message

Modifier and Type	Method	Description
Map<String,String>	AggregateIdentifierSpanAttributesProvider.provideForMessage(Message message)
Map<String,String>	MessageIdSpanAttributesProvider.provideForMessage(Message message)
Map<String,String>	MessageNameSpanAttributesProvider.provideForMessage(Message message)
Map<String,String>	MessageTypeSpanAttributesProvider.provideForMessage(Message message)
Map<String,String>	MetadataSpanAttributesProvider.provideForMessage(Message message)
Map<String,String>	PayloadTypeSpanAttributesProvider.provideForMessage(Message message)

Uses of Message in org.axonframework.modelling

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

Modifier and Type	Method	Description
ID	EntityIdResolver.resolve(Message message, ProcessingContext context)	Resolve the id of the entity from the given message and context.
Object	PropertyBasedEntityIdResolver.resolve(Message message, ProcessingContext context)

Uses of Message in org.axonframework.modelling.annotation

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

Modifier and Type	Method	Description
T	AnnotationBasedEntityIdResolver.resolve(Message message, ProcessingContext context)

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

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

Modifier and Type	Method	Description
boolean	AnnotatedEntityModelRoutingKeyMatcher.matches(E entity, Message message)	Matches the given entity against the provided message based on the routing keys of both.
ID	AnnotatedEntityIdResolver.resolve(Message message, ProcessingContext context)

Uses of Message in org.axonframework.test.fixture

Methods in org.axonframework.test.fixture that return Message

Modifier and Type	Method	Description
@Nullable Message	RecordingCommandBus.resultOf(CommandMessage command)	Returns the result of the given command.

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

Modifier and Type	Method	Description
Map<CommandMessage,Message>	RecordingCommandBus.recorded()	Returns map of all the CommandMessages dispatched, and their corresponding results.

Uses of Message in org.axonframework.test.matchers

Classes in org.axonframework.test.matchers with type parameters of type Message

Modifier and Type	Class	Description
class	PayloadMatcher<T extends Message>	Matcher that matches any message (e.g.

Methods in org.axonframework.test.matchers with type parameters of type Message

Modifier and Type	Method	Description
static <T extends Message> org.hamcrest.Matcher<T>	Matchers.messageWithPayload(org.hamcrest.Matcher<?> payloadMatcher)	Returns a Matcher that matches a single Message if the given payloadMatcher matches that message's payload.

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

Modifier and Type	Method	Description
static org.hamcrest.Matcher<List<? extends Message>>	Matchers.payloadsMatching(org.hamcrest.Matcher<? extends List<?>> matcher)	Returns a Matcher that matches a list of Message if a list containing their respective payloads matches the given matcher.

Uses of Message in org.axonframework.test.util

Methods in org.axonframework.test.util that return Message

Modifier and Type	Method	Description
Message	MessageMonitorReport.Report.Failure.message()	Returns the value of the message record component.
Message	MessageMonitorReport.Report.Ignored.message()	Returns the value of the message record component.
Message	MessageMonitorReport.Report.message()	Retrieves the message associated with the report.
Message	MessageMonitorReport.Report.Success.message()	Returns the value of the message record component.

Methods in org.axonframework.test.util with parameters of type Message

Modifier and Type	Method	Description
static MessageMonitorReport.Report.Failure	MessageMonitorReport.failure(Message message, Throwable cause)	Creates a new instance of MessageMonitorReport.Report.Failure with the specified message and cause.
static MessageMonitorReport.Report.Ignored	MessageMonitorReport.ignored(Message message)	Creates a new instance of MessageMonitorReport.Report.Ignored with the specified message.
final MessageMonitor.MonitorCallback	RecordingMessageMonitor.onMessageIngested(Message message)
protected void	RecordingMessageMonitor.onReportFailure(Message message, Throwable cause)	Hook for subclasses to perform additional actions when a message is reported as failed.
protected void	RecordingMessageMonitor.onReportIgnored(Message message)	Hook for subclasses to perform additional actions when a message is reported as ignored.
protected void	RecordingMessageMonitor.onReportSuccess(Message message)	Hook for subclasses to perform additional actions when a message is reported as successful.
static MessageMonitorReport.Report.Success	MessageMonitorReport.success(Message message)	Creates a new instance of MessageMonitorReport.Report.Success with the specified message.

Constructors in org.axonframework.test.util with parameters of type Message

Modifier	Constructor	Description
	Failure(Message message, Throwable cause)	Creates an instance of a Failure record class.
	Ignored(Message message)	Creates an instance of a Ignored record class.
	Success(Message message)	Creates an instance of a Success record class.