Uses of Interface
org.axonframework.messaging.Message

Packages that use Message

Package	Description
org.axonframework.axonserver.connector
org.axonframework.axonserver.connector.command
org.axonframework.axonserver.connector.query
org.axonframework.axonserver.connector.query.subscription
org.axonframework.axonserver.connector.util
org.axonframework.commandhandling	Classes that implement the concept of command handling using explicit command objects.
org.axonframework.config
org.axonframework.deadline
org.axonframework.disruptor.commandhandling
org.axonframework.eventhandling	Classes related to event handling and dispatching, such as Event Listeners and the Event Bus.
org.axonframework.eventhandling.replay
org.axonframework.eventsourcing.conflictresolution
org.axonframework.messaging	Classes related to message processing in Axon Framework.
org.axonframework.messaging.annotation
org.axonframework.messaging.correlation
org.axonframework.messaging.deadletter
org.axonframework.messaging.interceptors
org.axonframework.messaging.responsetypes
org.axonframework.messaging.unitofwork
org.axonframework.metrics
org.axonframework.micrometer
org.axonframework.modelling.command
org.axonframework.modelling.command.inspection
org.axonframework.modelling.saga
org.axonframework.monitoring
org.axonframework.queryhandling
org.axonframework.serialization	Classes related to message processing in Axon Framework.
org.axonframework.spring.config
org.axonframework.springboot.autoconfig
org.axonframework.test.matchers
org.axonframework.tracing
org.axonframework.tracing.attributes
org.axonframework.tracing.opentelemetry

Uses of Message in org.axonframework.axonserver.connector

Classes in org.axonframework.axonserver.connector with type parameters of type Message

Modifier and Type	Class and Description
class	DispatchInterceptors<M extends Message<?>> Composite of MessageDispatchInterceptors that apply all interceptors in the order of registration.
interface	TargetContextResolver<T extends Message<?>> Interface towards a mechanism that is capable of resolving the context name to which a Message should be routed.

Methods in org.axonframework.axonserver.connector that return types with arguments of type Message

Modifier and Type	Method and Description
static TargetContextResolver<Message<?>>	TargetContextResolver.noOp() Returns a no-op TargetContextResolver.

Uses of Message in org.axonframework.axonserver.connector.command

Classes in org.axonframework.axonserver.connector.command that implement Message

Modifier and Type	Class and Description
class	GrpcBackedCommandMessage<C> Wrapper that allows clients to access a gRPC Command as a CommandMessage.

Uses of Message in org.axonframework.axonserver.connector.query

Classes in org.axonframework.axonserver.connector.query that implement Message

Modifier and Type	Class and Description
class	GrpcBackedQueryMessage<Q,R> Wrapper that allows clients to access a gRPC QueryRequest as a QueryMessage.
class	GrpcBackedResponseMessage<R> Wrapper that allows clients to access a gRPC QueryResponse as a QueryResponseMessage.

Uses of Message in org.axonframework.axonserver.connector.query.subscription

Classes in org.axonframework.axonserver.connector.query.subscription that implement Message

Modifier and Type	Class and Description
class	GrpcBackedSubscriptionQueryMessage<Q,I,U> Wrapper that allows clients to access a gRPC SubscriptionQuery message as a SubscriptionQueryMessage.

Uses of Message in org.axonframework.axonserver.connector.util

Methods in org.axonframework.axonserver.connector.util with parameters of type Message

Modifier and Type	Method and Description
io.axoniq.axonserver.grpc.SerializedObject	GrpcPayloadSerializer.apply(Message message)

Uses of Message in org.axonframework.commandhandling

Subinterfaces of Message in org.axonframework.commandhandling

Modifier and Type	Interface and Description
interface	CommandMessage<T> Represents a Message carrying a command as its payload.
interface	CommandResultMessage<R> Message that represents a result from handling a CommandMessage.

Classes in org.axonframework.commandhandling that implement Message

Modifier and Type	Class and Description
class	GenericCommandMessage<T> Implementation of the CommandMessage that takes all properties as constructor parameters.
class	GenericCommandResultMessage<R> Generic implementation of CommandResultMessage.

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

Modifier and Type	Method and Description
boolean	CurrentUnitOfWorkParameterResolverFactory.matches(Message message)
Object	CurrentUnitOfWorkParameterResolverFactory.resolveParameterValue(Message message)

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

Constructor and Description
GenericCommandMessage(Message<T> delegate, String commandName) Create a CommandMessage from the given delegate message containing payload, metadata and message identifier, and the given commandName.
GenericCommandResultMessage(Message<R> delegate) Creates a new Command Result Message with given delegate message.
GenericCommandResultMessage(Message<R> delegate, Throwable exception) Creates a Command Result Message with given delegate message and exception.

Uses of Message in org.axonframework.config

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

Modifier and Type	Method and Description
<M extends Message<?>> MessageMonitor<? super M>	Configuration.messageMonitor(Class<?> componentType, String componentName) Returns the message monitor configured for a component of given componentType and componentName.

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

Modifier and Type	Method and Description
MessageMonitor<Message<?>>	MessageMonitorFactory.create(Configuration configuration, Class<?> componentType, String componentName) Function to create a Message Monitor based on the given configuration, component type and component name.
MessageMonitor<? super Message<?>>	EventProcessingModule.messageMonitor(Class<?> componentType, String eventProcessorName)
MessageMonitor<? super Message<?>>	EventProcessingConfiguration.messageMonitor(Class<?> componentType, String componentName) Returns the MessageMonitor set to the given componentType and componentName registered within this configuration.

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

Modifier and Type	Method and Description
default Configurer	Configurer.configureMessageMonitor(Class<?> componentType, Function<Configuration,MessageMonitor<Message<?>>> messageMonitorBuilder) Configures the builder function to create the Message Monitor for the Message processing components in this configuration that match the given componentType, unless more specific configuration based on both type and name is available.
default Configurer	Configurer.configureMessageMonitor(Class<?> componentType, String componentName, Function<Configuration,MessageMonitor<Message<?>>> messageMonitorBuilder) Configures the builder function to create the Message Monitor for the Message processing components in this configuration that match the given class and name.
Configurer	DefaultConfigurer.configureMessageMonitor(Function<Configuration,BiFunction<Class<?>,String,MessageMonitor<Message<?>>>> builder)
Configurer	Configurer.configureMessageMonitor(Function<Configuration,BiFunction<Class<?>,String,MessageMonitor<Message<?>>>> messageMonitorFactoryBuilder) Configures the Message Monitor to use for the Message processing components in this configuration, unless more specific configuration based on the component's type, or type and name is available.
default EventProcessingConfigurer	EventProcessingConfigurer.registerMessageMonitor(String eventProcessorName, Function<Configuration,MessageMonitor<Message<?>>> messageMonitorBuilder) Registers a builder Function to create the MessageMonitor for a EventProcessor of the given name.

Uses of Message in org.axonframework.deadline

Subinterfaces of Message in org.axonframework.deadline

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

Classes in org.axonframework.deadline that implement Message

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

Constructors in org.axonframework.deadline with parameters of type Message

Constructor and Description
GenericDeadlineMessage(String deadlineName, Message<T> delegate, Supplier<Instant> timestampSupplier) Constructor to reconstruct a DeadlineMessage using existing data.

Uses of Message in org.axonframework.disruptor.commandhandling

Classes in org.axonframework.disruptor.commandhandling with type parameters of type Message

Modifier and Type	Class and Description
class	DisruptorUnitOfWork<T extends Message<?>> Specialized UnitOfWork instance for the DisruptorCommandBus.

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

Modifier and Type	Method and Description
UnitOfWork<T>	DisruptorUnitOfWork.transformMessage(Function<T,? extends Message<?>> transformOperator)

Uses of Message in org.axonframework.eventhandling

Subinterfaces of Message in org.axonframework.eventhandling

Modifier and Type	Interface and Description
interface	DomainEventMessage<T> Represents a Message that wraps a DomainEvent and an Event representing an important change in the Domain.
interface	EventMessage<T> Represents a Message wrapping an Event, which is represented by its payload.
interface	TrackedEventMessage<T> Represents an EventMessage containing a TrackingToken.

Classes in org.axonframework.eventhandling that implement Message

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

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

Modifier and Type	Method and Description
static boolean	ReplayToken.isReplay(Message<?> message) Indicates whether the given message is "redelivered", as a result of a previous reset.
boolean	SequenceNumberParameterResolverFactory.SequenceNumberParameterResolver.matches(Message message)
boolean	ConcludesBatchParameterResolverFactory.matches(Message<?> message)
Long	SequenceNumberParameterResolverFactory.SequenceNumberParameterResolver.resolveParameterValue(Message message)
Boolean	ConcludesBatchParameterResolverFactory.resolveParameterValue(Message<?> message)

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

Constructor and Description
GenericDomainEventMessage(String type, String aggregateIdentifier, long sequenceNumber, Message<T> delegate, Instant timestamp) Initialize a DomainEventMessage originating from an Aggregate with the given aggregateIdentifier, with given sequenceNumber and payload, metaData and timestamp.
GenericDomainEventMessage(String type, String aggregateIdentifier, long sequenceNumber, Message<T> delegate, Supplier<Instant> timestamp) Initialize a DomainEventMessage originating from an Aggregate using existing data.
GenericEventMessage(Message<T> delegate, Instant timestamp) Initializes a GenericEventMessage with given message as delegate and given timestamp.
GenericEventMessage(Message<T> delegate, Supplier<Instant> timestampSupplier) Constructor to reconstruct an EventMessage using existing data.
GenericTrackedDomainEventMessage(TrackingToken trackingToken, String type, String aggregateIdentifier, long sequenceNumber, Message<T> delegate, Instant timestamp) Initialize a DomainEventMessage originating from an aggregate.
GenericTrackedDomainEventMessage(TrackingToken trackingToken, String type, String aggregateIdentifier, long sequenceNumber, Message<T> delegate, Supplier<Instant> timestamp) Initialize a DomainEventMessage originating from an Aggregate using existing data.
GenericTrackedEventMessage(TrackingToken trackingToken, Message<T> delegate, Instant timestamp) Initializes a GenericTrackedEventMessage with given message as delegate and given timestamp.
GenericTrackedEventMessage(TrackingToken trackingToken, Message<T> delegate, Supplier<Instant> timestamp) Creates a GenericTrackedEventMessage with given trackingToken and delegate event message.

Uses of Message in org.axonframework.eventhandling.replay

Subinterfaces of Message in org.axonframework.eventhandling.replay

Modifier and Type	Interface and Description
interface	ResetContext<T> Represents a Message initiating the reset of an Event Handling Component.

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

Modifier and Type	Class and Description
class	GenericResetContext<T> Generic implementation of the ResetContext.

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

Constructor and Description
GenericResetContext(Message<T> message)

Uses of Message in org.axonframework.eventsourcing.conflictresolution

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

Modifier and Type	Method and Description
boolean	ConflictResolution.matches(Message<?> message)
ConflictResolver	ConflictResolution.resolveParameterValue(Message<?> message)

Uses of Message in org.axonframework.messaging

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

Modifier and Type	Class and Description
class	DefaultInterceptorChain<T extends Message<?>> Mechanism that takes care of interceptor and handler execution.
interface	MessageDispatchInterceptor<T extends Message<?>> Interceptor that allows messages to be intercepted and modified before they are dispatched.
interface	MessageDispatchInterceptorSupport<T extends Message<?>> Interface marking components capable of registering Dispatch Interceptors.
interface	MessageHandler<T extends Message<?>> Interface for a component that processes Messages.
interface	MessageHandlerInterceptor<T extends Message<?>> Workflow interface that allows for customized message handler invocation chains.
interface	MessageHandlerInterceptorSupport<T extends Message<?>> Interface marking components capable of registering Handler Interceptors.
interface	StreamableMessageSource<M extends Message<?>> Interface for a source of messages that processors can track.
interface	SubscribableMessageSource<M extends Message<?>> Interface for a source of messages to which message processors can subscribe.

Subinterfaces of Message in org.axonframework.messaging

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

Classes in org.axonframework.messaging that implement Message

Modifier and Type	Class and Description
class	AbstractMessage<T> Abstract base class for Messages.
class	GenericMessage<T> Generic implementation of a Message that contains the payload and metadata as unserialized values.
class	GenericResultMessage<R> Generic implementation of ResultMessage.
class	MessageDecorator<T> Abstract implementation of a Message that delegates to an existing message.

Methods in org.axonframework.messaging that return Message

Modifier and Type	Method and Description
Message<T>	Message.andMetaData(Map<String,?> metaData) Returns a copy of this Message with it MetaData merged with the given metaData.
Message<T>	AbstractMessage.andMetaData(Map<String,?> metaData)
static Message<?>	GenericMessage.asMessage(Object payloadOrMessage) Returns a Message representing the given payloadOrMessage, either by wrapping it or by returning it as-is.
protected Message<T>	MessageDecorator.getDelegate() Returns the wrapped message delegate.
Message<T>	Message.withMetaData(Map<String,?> metaData) Returns a copy of this Message with the given metaData.
Message<T>	AbstractMessage.withMetaData(Map<String,?> metaData)
protected Message<T>	GenericMessage.withMetaData(MetaData metaData)
protected abstract Message<T>	AbstractMessage.withMetaData(MetaData metaData) Returns a new message instance with the same payload and properties as this message but given metaData.

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

Modifier and Type	Method and Description
void	ScopeAware.send(Message<?> message, ScopeDescriptor scopeDescription) Send a Message to a Scope which is described by the given scopeDescription.

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

Constructor and Description
GenericResultMessage(Message<R> delegate) Creates a new ResultMessage with given delegate message.
GenericResultMessage(Message<R> delegate, Throwable exception) Creates a ResultMessage with given delegate message and exception.
MessageDecorator(Message<T> delegate) Initializes a new decorator with given delegate message.

Uses of Message in org.axonframework.messaging.annotation

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

Modifier and Type	Method and Description
boolean	WrappedMessageHandlingMember.canHandle(Message<?> message)
boolean	MessageHandlingMember.canHandle(Message<?> message) Checks if this handler is capable of handling the given message.
boolean	AnnotatedMessageHandlingMember.canHandle(Message<?> message)
Object	WrappedMessageHandlingMember.handle(Message<?> message, T target)
Object	MessageHandlingMember.handle(Message<?> message, T target) Handles the given message by invoking the appropriate method on given target.
Object	AnnotatedMessageHandlingMember.handle(Message<?> message, T target)
Object	MessageHandlerInterceptorMemberChain.handle(Message<?> message, T target, MessageHandlingMember<? super T> handler) Handle the given message by passing it through the interceptors and ultimately to the given handler on the given target instance.
boolean	PayloadParameterResolver.matches(Message message)
boolean	FixedValueParameterResolver.matches(Message message)
boolean	ParameterResolver.matches(Message<?> message) Indicates whether this resolver is capable of providing a value for the given message.
boolean	InterceptorChainParameterResolverFactory.matches(Message<?> message)
protected boolean	AnnotatedMessageHandlingMember.parametersMatch(Message<?> message) Checks if the parameter resolvers of this member are compatible with the given message.
Object	PayloadParameterResolver.resolveParameterValue(Message message)
T	FixedValueParameterResolver.resolveParameterValue(Message message)
T	ParameterResolver.resolveParameterValue(Message<?> message) Resolves the parameter value to use for the given message, or null if no suitable parameter value can be resolved.
InterceptorChain	InterceptorChainParameterResolverFactory.resolveParameterValue(Message<?> message)
protected boolean	AnnotatedMessageHandlingMember.typeMatches(Message<?> message) Checks if this member can handle the type of the given message.

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

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

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

Constructor and Description
AnnotatedMessageHandlingMember(Executable executable, Class<? extends Message> messageType, Class<?> explicitPayloadType, ParameterResolverFactory parameterResolverFactory) 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.correlation

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

Modifier and Type	Class and Description
class	MultiCorrelationDataProvider<T extends Message> CorrelationDataProvider that combines the data of multiple other correlation providers.

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

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

Uses of Message in org.axonframework.messaging.deadletter

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

Modifier and Type	Interface and 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.
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 org.axonframework.messaging.deadletter with type parameters of type Message

Modifier and Type	Method and 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 org.axonframework.messaging.interceptors

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

Modifier and Type	Class and Description
class	BeanValidationInterceptor<T extends Message<?>> Interceptor that applies JSR303 bean validation on incoming Messages.
class	CorrelationDataInterceptor<T extends Message<?>> Message interceptor that registers CorrelationDataProviders with the Unit of Work.
class	LoggingInterceptor<T extends Message<?>> MessageDispatchInterceptor and MessageHandlerInterceptor implementation that logs dispatched and incoming messages, and their result, to a SLF4J logger.
class	TransactionManagingInterceptor<T extends Message<?>> Interceptor that uses a TransactionManager to start a new transaction before a Message is handled.

Uses of Message in org.axonframework.messaging.responsetypes

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

Modifier and Type	Class and Description
class	ConvertingResponseMessage<R> Implementation of a QueryResponseMessage that is aware of the requested response type and performs a just-in-time conversion to ensure the response is formatted as requested.

Uses of Message in org.axonframework.messaging.unitofwork

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

Modifier and Type	Class and Description
class	AbstractUnitOfWork<T extends Message<?>> Abstract implementation of the Unit of Work.
class	BatchingUnitOfWork<T extends Message<?>> Unit of Work implementation that is able to process a batch of Messages instead of just a single Message.
class	DefaultUnitOfWork<T extends Message<?>> Implementation of the UnitOfWork that processes a single message.
class	MessageProcessingContext<T extends Message<?>> Maintains the context around the processing of a single Message.
interface	UnitOfWork<T extends Message<?>> This class represents a Unit of Work that monitors the processing of a Message.

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

Modifier and Type	Method and Description
static <T extends Message<?>> DefaultUnitOfWork<T>	DefaultUnitOfWork.startAndGet(T message) Starts a new DefaultUnitOfWork instance, registering it a CurrentUnitOfWork.

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

Modifier and Type	Method and Description
Map<Message<?>,ExecutionResult>	BatchingUnitOfWork.getExecutionResults() Returns a Map of ExecutionResult per Message.

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

Modifier and Type	Method and Description
boolean	BatchingUnitOfWork.isFirstMessage(Message<?> message) Checks if the given message is the first of the batch being processed in this unit of work.
boolean	BatchingUnitOfWork.isLastMessage(Message<?> message) Checks if the given message is the last of the batch being processed in this unit of work.

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

Modifier and Type	Method and Description
UnitOfWork<T>	UnitOfWork.transformMessage(Function<T,? extends Message<?>> transformOperator) Transform the Message being processed using the given operator and stores the result.
void	MessageProcessingContext.transformMessage(Function<T,? extends Message<?>> transformOperator) Transform the Message being processed using the given operator.
UnitOfWork<T>	DefaultUnitOfWork.transformMessage(Function<T,? extends Message<?>> transformOperator)
UnitOfWork<T>	BatchingUnitOfWork.transformMessage(Function<T,? extends Message<?>> transformOperator)

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

Constructor and Description
BatchingUnitOfWork(T... messages) Initializes a BatchingUnitOfWork for processing the given batch of messages.

Uses of Message in org.axonframework.metrics

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

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

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

Modifier and Type	Method and Description
MessageMonitor<? extends Message<?>>	GlobalMetricRegistry.registerComponent(Class<?> componentType, String componentName) Registers new metrics to the MetricRegistry to monitor a component of given componentType.

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

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

Uses of Message in org.axonframework.micrometer

Classes in org.axonframework.micrometer with type parameters of type Message

Modifier and Type	Class and Description
class	PayloadTypeMessageMonitorWrapper<T extends MessageMonitor<Message<?>>> Deprecated. As of release 4.4, replaced by using Tags on the monitor implementations. Use {@link org.axonframework.micrometer.GlobalMetricRegistry#registerWithConfigurerWithDefaultTags(Configurer) to achieve the same behavior as this implementation.

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

Modifier and Type	Field and Description
static Function<Message<?>,Iterable<io.micrometer.core.instrument.Tag>>	TagsUtil.META_DATA_TAGGER_FUNCTION The function for creating the Micrometer Tags based on the message metadata.
static Function<Message<?>,Iterable<io.micrometer.core.instrument.Tag>>	TagsUtil.PAYLOAD_TYPE_TAGGER_FUNCTION The function for creating the Micrometer Tags based on the message payload type.

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

Modifier and Type	Method and Description
MessageMonitor<? extends Message<?>>	GlobalMetricRegistry.registerComponent(Class<?> componentType, String componentName) Registers new metrics to the registry to monitor a component of the given componentType.
MessageMonitor<? extends Message<?>>	GlobalMetricRegistry.registerComponentWithDefaultTags(Class<?> componentType, String componentName) Registers new metrics to the registry to monitor a component of the given componentType.

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

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

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

Modifier and Type	Method and Description
static MessageTimerMonitor	MessageTimerMonitor.buildMonitor(String meterNamePrefix, io.micrometer.core.instrument.MeterRegistry meterRegistry, io.micrometer.core.instrument.Clock clock, Function<Message<?>,Iterable<io.micrometer.core.instrument.Tag>> tagsBuilder) Deprecated. in favor of using the MessageTimerMonitor.builder()
static MessageTimerMonitor	MessageTimerMonitor.buildMonitor(String meterNamePrefix, io.micrometer.core.instrument.MeterRegistry meterRegistry, Function<Message<?>,Iterable<io.micrometer.core.instrument.Tag>> tagsBuilder) Deprecated. in favor of using the MessageTimerMonitor.builder()
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
static EventProcessorLatencyMonitor	EventProcessorLatencyMonitor.buildMonitor(String meterNamePrefix, io.micrometer.core.instrument.MeterRegistry meterRegistry, Function<Message<?>,Iterable<io.micrometer.core.instrument.Tag>> tagsBuilder) Deprecated. in favor of using the EventProcessorLatencyMonitor.builder()
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 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.
MessageMonitor<? super CommandMessage<?>>	GlobalMetricRegistry.registerCommandBus(String commandBusName, Function<Message<?>,Iterable<io.micrometer.core.instrument.Tag>> tagsBuilder) Registers new metrics to the registry to monitor a CommandBus using Tags through the given tagsBuilder.
MessageMonitor<? super EventMessage<?>>	GlobalMetricRegistry.registerEventBus(String eventBusName, Function<Message<?>,Iterable<io.micrometer.core.instrument.Tag>> tagsBuilder) Registers new metrics to the registry to monitor an EventBus using Tags through the given tagsBuilder.
MessageMonitor<? super EventMessage<?>>	GlobalMetricRegistry.registerEventProcessor(String eventProcessorName, Function<Message<?>,Iterable<io.micrometer.core.instrument.Tag>> tagsBuilder) Registers new metrics to the registry to monitor an EventProcessor using Tags through the given tagsBuilder.
MessageMonitor<? super QueryMessage<?,?>>	GlobalMetricRegistry.registerQueryBus(String queryBusName, Function<Message<?>,Iterable<io.micrometer.core.instrument.Tag>> tagsBuilder) Registers new metrics to the registry to monitor a QueryBus using Tags through the given tagsBuilder.
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.
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.

Uses of Message in org.axonframework.modelling.command

Classes in org.axonframework.modelling.command with type parameters of type Message

Modifier and Type	Interface and Description
interface	ForwardingMode<T extends Message<?>> Interface describing the required functionality to forward a message.
class	ForwardMatchingInstances<T extends Message<?>> Only forward messages of type T if the routing key of the message matches that of the entity.
class	ForwardNone<T extends Message<?>> Forward no messages T regardless of their set up.
class	ForwardToAll<T extends Message<?>> Forward all messages T regardless of their set up.

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

Modifier and Type	Method and Description
Object	LockAwareAggregate.handle(Message<?> message)
Object	Aggregate.handle(Message<?> message) Handle the given message on the aggregate root or one of its child entities.
void	AbstractRepository.send(Message<?> message, ScopeDescriptor scopeDescription)

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

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

Modifier and Type	Method and Description
boolean	ChildForwardingCommandMessageHandlingMember.canHandle(Message<?> message)
Object	AnnotatedAggregate.handle(Message<?> message)
Object	ChildForwardingCommandMessageHandlingMember.handle(Message<?> message, P target)

Method parameters in org.axonframework.modelling.command.inspection with type arguments of type Message

Modifier and Type	Method and Description
boolean	ChildForwardingCommandMessageHandlingMember.canHandleMessageType(Class<? extends Message> messageType)

Uses of Message in org.axonframework.modelling.saga

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

Modifier and Type	Method and Description
Object	SagaMethodMessageHandlingMember.handle(Message<?> message, T target)
Object	EndSagaMessageHandlerDefinition.EndSageMessageHandlingMember.handle(Message<?> message, T target)
void	AbstractSagaManager.send(Message<?> message, ScopeDescriptor scopeDescription)

Uses of Message in org.axonframework.monitoring

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

Modifier and Type	Interface and 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.monitoring with parameters of type Message

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

Uses of Message in org.axonframework.queryhandling

Subinterfaces of Message in org.axonframework.queryhandling

Modifier and Type	Interface and Description
interface	QueryMessage<T,R> Message type that carries a Query: a request for information.
interface	QueryResponseMessage<T> Message that contains the results of a Query.
interface	StreamingQueryMessage<Q,R> A special type of QueryMessage used for initiating streaming queries.
interface	SubscriptionQueryMessage<Q,I,U> Message type that carries a Subscription Query: a request for information.
interface	SubscriptionQueryUpdateMessage<U> Message which holds incremental update of an subscription query.

Classes in org.axonframework.queryhandling that implement Message

Modifier and Type	Class and Description
class	GenericQueryMessage<T,R> Generic implementation of the QueryMessage.
class	GenericQueryResponseMessage<R> QueryResponseMessage implementation that takes all properties as constructor parameters.
class	GenericStreamingQueryMessage<Q,R> Generic implementation of the StreamingQueryMessage.
class	GenericSubscriptionQueryMessage<Q,I,U> Generic implementation of the SubscriptionQueryMessage.
class	GenericSubscriptionQueryUpdateMessage<U> Generic SubscriptionQueryUpdateMessage which holds incremental update of an subscription query.

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

Constructor and Description
GenericQueryMessage(Message<T> delegate, String queryName, ResponseType<R> responseType) Initialize the Query Message, using given delegate as the carrier of payload and metadata and given queryName and expecting the given responseType.
GenericQueryResponseMessage(Message<R> delegate) Copy-constructor that takes the payload, meta data and message identifier of the given delegate for this message.
GenericQueryResponseMessage(Message<R> delegate, Throwable exception) Copy-constructor that takes the payload, meta data and message identifier of the given delegate for this message and given exception as a cause for the failure.
GenericStreamingQueryMessage(Message<Q> delegate, String queryName, Class<R> responseType) Initializes the message with the given delegate, queryName and expected responseType.
GenericStreamingQueryMessage(Message<Q> delegate, String queryName, ResponseType<org.reactivestreams.Publisher<R>> responseType) Initialize the Query Message, using given delegate as the carrier of payload and metadata and given queryName and expecting the given responseType.
GenericSubscriptionQueryMessage(Message<Q> delegate, String queryName, ResponseType<I> responseType, ResponseType<U> updateResponseType) Initializes the message, using given delegate as the carrier of payload and metadata and given queryName, expected responseType and expected updateResponseType.
GenericSubscriptionQueryUpdateMessage(Message<U> delegate) Initializes a new decorator with given delegate message.

Uses of Message in org.axonframework.serialization

Classes in org.axonframework.serialization that implement Message

Modifier and Type	Class and Description
class	SerializedMessage<T> A message containing serialized payload data and metadata.

Constructors in org.axonframework.serialization with parameters of type Message

Constructor and Description
SerializedObjectHolder(Message message) Initialize the holder for the serialized representations of the payload and meta data of given message

Uses of Message in org.axonframework.spring.config

Methods in org.axonframework.spring.config with type parameters of type Message

Modifier and Type	Method and Description
<M extends Message<?>> MessageMonitor<? super M>	AxonConfiguration.messageMonitor(Class<?> componentType, String componentName) Deprecated.

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

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

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

Modifier and Type	Method and 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.springboot.autoconfig

Methods in org.axonframework.springboot.autoconfig that return types with arguments of type Message

Modifier and Type	Method and Description
TargetContextResolver<Message<?>>	AxonServerAutoConfiguration.targetContextResolver()

Uses of Message in org.axonframework.test.matchers

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

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

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

Modifier and Type	Method and Description
static org.hamcrest.Matcher<Message<?>>	Matchers.messageWithPayload(org.hamcrest.Matcher<?> payloadMatcher) Matches a single Message if the given payloadMatcher matches that message's payload.
static org.hamcrest.Matcher<List<Message<?>>>	Matchers.payloadsMatching(org.hamcrest.Matcher<? extends List<?>> matcher) Matches a list of Messages if a list containing their respective payloads matches the given matcher.

Uses of Message in org.axonframework.tracing

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

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

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

Modifier and Type	Method and Description
default Span	SpanFactory.createChildHandlerSpan(Supplier<String> operationNameSupplier, Message<?> parentMessage, Message<?>... linkedParents) Creates a new Span which is part of the current trace.
default Span	SpanFactory.createChildHandlerSpan(Supplier<String> operationNameSupplier, Message<?> parentMessage, Message<?>... linkedParents) Creates a new Span which is part of the current trace.
Span	SpanFactory.createDispatchSpan(Supplier<String> operationNameSupplier, Message<?> parentMessage, Message<?>... linkedSiblings) Creates a new Span linked to dispatching a Message, for example when sending a command to Axon Server.
Span	SpanFactory.createDispatchSpan(Supplier<String> operationNameSupplier, Message<?> parentMessage, Message<?>... linkedSiblings) Creates a new Span linked to dispatching a Message, for example when sending a command to Axon Server.
Span	NoOpSpanFactory.createDispatchSpan(Supplier<String> operationNameSupplier, Message<?> parentMessage, Message<?>... linkedSiblings)
Span	NoOpSpanFactory.createDispatchSpan(Supplier<String> operationNameSupplier, Message<?> parentMessage, Message<?>... linkedSiblings)
Span	MultiSpanFactory.createDispatchSpan(Supplier<String> operationNameSupplier, Message<?> parentMessage, Message<?>... linkedSiblings)
Span	MultiSpanFactory.createDispatchSpan(Supplier<String> operationNameSupplier, Message<?> parentMessage, Message<?>... linkedSiblings)
Span	LoggingSpanFactory.createDispatchSpan(Supplier<String> operationNameSupplier, Message<?> parentMessage, Message<?>... linkedSiblings)
Span	LoggingSpanFactory.createDispatchSpan(Supplier<String> operationNameSupplier, Message<?> parentMessage, Message<?>... linkedSiblings)
Span	SpanFactory.createHandlerSpan(Supplier<String> operationNameSupplier, Message<?> parentMessage, boolean isChildTrace, Message<?>... linkedParents) Creates a new Span linked to asynchronously handling a Message, for example when handling a command from Axon Server.
Span	SpanFactory.createHandlerSpan(Supplier<String> operationNameSupplier, Message<?> parentMessage, boolean isChildTrace, Message<?>... linkedParents) Creates a new Span linked to asynchronously handling a Message, for example when handling a command from Axon Server.
Span	NoOpSpanFactory.createHandlerSpan(Supplier<String> operationNameSupplier, Message<?> parentMessage, boolean isChildTrace, Message<?>... linkedParents)
Span	NoOpSpanFactory.createHandlerSpan(Supplier<String> operationNameSupplier, Message<?> parentMessage, boolean isChildTrace, Message<?>... linkedParents)
Span	MultiSpanFactory.createHandlerSpan(Supplier<String> operationNameSupplier, Message<?> parentMessage, boolean isChildTrace, Message<?>... linkedParents)
Span	MultiSpanFactory.createHandlerSpan(Supplier<String> operationNameSupplier, Message<?> parentMessage, boolean isChildTrace, Message<?>... linkedParents)
Span	LoggingSpanFactory.createHandlerSpan(Supplier<String> operationNameSupplier, Message<?> parentMessage, boolean isChildTrace, Message<?>... linkedParents)
Span	LoggingSpanFactory.createHandlerSpan(Supplier<String> operationNameSupplier, Message<?> parentMessage, boolean isChildTrace, Message<?>... linkedParents)
Span	SpanFactory.createInternalSpan(Supplier<String> operationNameSupplier, Message<?> message) Creates a new Span linked to the currently active span.
Span	NoOpSpanFactory.createInternalSpan(Supplier<String> operationNameSupplier, Message<?> message)
Span	MultiSpanFactory.createInternalSpan(Supplier<String> operationNameSupplier, Message<?> message)
Span	LoggingSpanFactory.createInternalSpan(Supplier<String> operationNameSupplier, Message<?> message)
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.
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's payload.
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.tracing.attributes

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

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

Uses of Message in org.axonframework.tracing.opentelemetry

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

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

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

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

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

Modifier and Type	Method and 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.