Package org.axonframework.messaging.core

@NullMarked package org.axonframework.messaging.core

Classes related to message processing in Axon Framework.

Related Packages

Package	Description
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.reflection	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.timeout	Part of the Axon Messaging module.
org.axonframework.messaging.core.unitofwork	Part of the Axon Messaging module.

Class	Description
AbstractMessage	Abstract base class for Messages.
AbstractMessageStream<M extends Message>	Abstract implementation of MessageStream that provides basic state management for completion, errors, and callbacks.
ApplicationContext	An ApplicationContext is a container for components that are registered in the ComponentRegistry of the ApplicationConfigurer.
ClassBasedMessageTypeResolver	A MessageTypeResolver using the Class of the given payload to base the type on.
CloseCallbackMessageStream<M extends Message>	MessageStream implementation that invokes the given closeHandler once the stream is closed.
ConfigurationApplicationContext	An ApplicationContext implementation that retrieves components from a given Configuration.
Context	Interface describing operations for context-specific, immutable, resource management.
Context.ResourceKey<T>	Object that is used as a key to retrieve and register resources of a given type in a Context.
DefaultMessageDispatchInterceptorChain<M extends Message>	Default implementation for a MessageDispatchInterceptorChain.
DelayedMessageStream<M extends Message>	An implementation of the MessageStream that wraps a stream that will become available asynchronously.
DelegatingMessageStream<DM extends Message,RM extends Message>	Abstract implementation of an MessageStream that delegates calls to a given delegate.
Distributed<MessageBus>	A contract towards being a distributed message bus implementation.
EmptyApplicationContext	An ApplicationContext implementation that does not provide any components.
EventPublicationFailedException	Exception indication that an error occurred while publishing an event to an AMQP Broker
ExecutionException	Exception thrown to indicate that execution of a task has failed.
FluxUtils	Utility methods to work with Project Reactor's fluxes.
GenericMessage	Generic implementation of the Message interface containing the payload and metadata in deserialized form.
GenericResultMessage	Generic implementation of ResultMessage interface.
HandlerExecutionException	Base exception for exceptions raised by Handler methods.
HierarchicalMessageTypeResolver	Implementation of MessageTypeResolver that combines two resolvers in a fallback pattern.
IllegalPayloadAccessException	Indicates situations when access to the Payload of a Message is not allowed.
LegacyResources	Utility class to obtain resources used in previous versions of Axon Framework.
MergedMessageStream<M extends Message>	A MessageStream implementation that merges two underlying message streams into a single stream.
Message	Representation of a Message, containing a type, payload, and Metadata.
MessageDecorator	Abstract implementation of a Message that delegates to an existing message.
MessageDispatchInterceptor<M extends Message>	Interceptor that allows messages to be intercepted and modified before they are dispatched.
MessageDispatchInterceptorChain<M extends Message>	An interceptor chain that manages the flow of a Message of type M through a chain of interceptors.
MessageHandler	Marker interface for a handlers or components of messages.
MessageHandlerInterceptor<M extends Message>	Workflow interface that allows for customized message handler invocation chains.
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.
MessageStream<M extends Message>	Represents a stream of entries containing Messages of type M that can be consumed as they become available.
MessageStream.Empty<M extends Message>	A MessageStream implementation that completes normally or with an error without returning any elements.
MessageStream.Entry<M extends Message>	A MessageStream-specific container of Message implementations.
MessageStream.Single<M extends Message>	A MessageStream implementation that returns at most a single result before completing.
MessageStreamUtils	Utility methods to work with MessageStreams.
MessageType	Record combining a qualified name and version.
MessageTypeNotResolvedException	Exception thrown when a MessageTypeResolver is unable to determine the MessageType for a given payload type.
MessageTypeResolver	Functional interface describing a resolver from Message payload to it's type.
Metadata	Represents metadata that is passed along with a payload in a Message.
MonoUtils	Utility methods to work with Project Reactor's monos.
NamespaceMessageTypeResolver	Implementation of the MessageTypeResolver that maintains a mapping of payload types to their corresponding MessageTypes.
NamespaceMessageTypeResolver.Builder	Builder interface for constructing a NamespaceMessageTypeResolver.
QualifiedName	Interface describing a qualified qualifiedName, providing space for a namespace, local qualifiedName.
QueueMessageStream<M extends Message>	MessageStream implementation that uses a Queue to make elements available to a consumer.
RemoteExceptionDescription	Description of an Exception received from a remote source.
RemoteHandlingException	Exception indicating that an error has occurred while remotely handling a message.
RemoteNonTransientHandlingException	Exception indicating that a non transient error has occurred while remotely handling a message.
ResultMessage	A Message that represents a result of handling some form of a request message.
SimpleContext	Implementation of the Context providing a basic implementation for context-specific resource management.
SimpleEntry<M extends Message>	Simple implementation of the MessageStream.Entry containing a single Message implementation of type M and a Context.
SimpleHandlerAttributes	Simple implementation of the HandlerAttributes which is given the attributes in the constructor.
SubscribableEventSource	Interface for a source of EventMessages to which event processors can subscribe.