Uses of Interface
org.axonframework.messaging.Message

Packages that use Message

Package	Description
org.axonframework.commandhandling	Classes that implement the concept of command handling using explicit command objects.
org.axonframework.commandhandling.conflictresolution
org.axonframework.commandhandling.disruptor
org.axonframework.commandhandling.model
org.axonframework.commandhandling.model.inspection
org.axonframework.config
org.axonframework.eventhandling	Classes related to event handling and dispatching, such as Event Listeners and the Event Bus.
org.axonframework.eventhandling.saga
org.axonframework.eventsourcing	Classes related to event sourcing.
org.axonframework.messaging	Classes related to message processing in Axon Framework.
org.axonframework.messaging.annotation
org.axonframework.messaging.correlation
org.axonframework.messaging.interceptors
org.axonframework.messaging.unitofwork
org.axonframework.metrics
org.axonframework.monitoring
org.axonframework.queryhandling
org.axonframework.serialization	Classes related to message processing in Axon Framework.
org.axonframework.spring.config
org.axonframework.test.matchers

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.

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.

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.

Uses of Message in org.axonframework.commandhandling.conflictresolution

Methods in org.axonframework.commandhandling.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.commandhandling.disruptor

Classes in org.axonframework.commandhandling.disruptor 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.commandhandling.disruptor 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.commandhandling.model

Classes in org.axonframework.commandhandling.model 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.

Uses of Message in org.axonframework.commandhandling.model.inspection

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

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

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.

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.
EventHandlingConfiguration	EventHandlingConfiguration.configureMessageMonitor(String name, Function<Configuration,MessageMonitor<Message<?>>> messageMonitorBuilder) Configures the builder function to create the Message Monitor for the EventProcessor of the given name.

Uses of Message in org.axonframework.eventhandling

Subinterfaces of Message in org.axonframework.eventhandling

Modifier and Type	Interface and Description
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	GenericEventMessage<T> Generic implementation of the EventMessage interface.
class	GenericTrackedEventMessage<T> Generic implementation of a TrackedEventMessage.

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

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

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

Constructor and Description
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.
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.saga

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

Modifier and Type	Method and Description
Object	SagaMethodMessageHandlingMember.handle(Message<?> message, T target)

Uses of Message in org.axonframework.eventsourcing

Subinterfaces of Message in org.axonframework.eventsourcing

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.

Classes in org.axonframework.eventsourcing that implement Message

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

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

Modifier and Type	Method and Description
boolean	SequenceNumberParameterResolverFactory.SequenceNumberParameterResolver.matches(Message message)
Long	SequenceNumberParameterResolverFactory.SequenceNumberParameterResolver.resolveParameterValue(Message message)

Constructors in org.axonframework.eventsourcing 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.
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.

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	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	MessageStream<M extends Message<?>> Interface for a tracked stream of Messages.
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.

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	MessageDecorator<T> Abstract implementation of a Message that delegates to an existing message.

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

Modifier and Type	Method and Description
static <M extends Message<?>> Stream<M>	StreamUtils.asStream(MessageStream<M> messageStream) Convert the given messageStream to a regular java Stream of messages.

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

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

Constructor and Description
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)
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.
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.
protected boolean	AnnotatedMessageHandlingMember.typeMatches(Message<?> message) Checks if this member can handle the type of the given message.

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.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<?>> Message Handler Interceptor that logs 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.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.
List<? extends Message<?>>	BatchingUnitOfWork.getMessages() Get the batch of messages that is being processed (or has been processed) by this unit of work.

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 registry to monitor a component of given type.

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

Classes in org.axonframework.queryhandling that implement Message

Modifier and Type	Class and Description
class	GenericQueryMessage<T,R> Generic implementation of the QueryMessage.

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

Constructor and Description
GenericQueryMessage(Message<T> delegate, String queryName, Class<R> responseType) Initialize the Query Message, using given delegate as the carrier of payload and metadata and given queryName and expecting the given responseType.

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.

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

Modifier and Type	Method and Description
<T> SerializedObject<T>	MessageSerializer.serializeMetaData(Message<?> message, Class<T> expectedRepresentation) Serialize the meta data of given message to the given expectedRepresentation.
static <T> SerializedObject<T>	MessageSerializer.serializeMetaData(Message<?> message, Serializer serializer, Class<T> expectedRepresentation) Utility method that serializes the meta data of the given message using given serializer and expectedRepresentation.
<T> SerializedObject<T>	MessageSerializer.serializePayload(Message<?> message, Class<T> expectedRepresentation) Serialize the payload of given message to the given expectedRepresentation.
static <T> SerializedObject<T>	MessageSerializer.serializePayload(Message<?> message, Serializer serializer, Class<T> expectedRepresentation) Utility method that serializes the payload of the given message using given serializer and expectedRepresentation.

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)

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.