Package org.axonframework.messaging.core
package org.axonframework.messaging.core
Classes related to message processing in Axon Framework.
-
ClassDescriptionAbstract base class for
Messages.AnApplicationContextis a container for components that are registered in theComponentRegistryof theApplicationConfigurer.CloseCallbackMessageStream<M extends Message>MessageStream implementation that invokes the givencloseHandleronce the stream is closed.AnApplicationContextimplementation that retrieves components from a givenConfiguration.Interface describing operations for context-specific, immutable, resource management.Object that is used as a key to retrieve and register resources of a given type in aContext.DefaultMessageDispatchInterceptorChain<M extends Message>Default implementation for aMessageDispatchInterceptorChain.DelayedMessageStream<M extends Message>An implementation of theMessageStreamthat wraps a stream that will become available asynchronously.Abstract implementation of an MessageStream that delegates calls to a given delegate.Distributed<MessageBus>A contract towards being a distributed message bus implementation.AnApplicationContextimplementation that does not provide any components.Exception indication that an error occurred while publishing an event to an AMQP BrokerException thrown to indicate that execution of a task has failed.Utility methods to work with Project Reactor'sfluxes.Generic implementation ofResultMessageinterface.Base exception for exceptions raised by Handler methods.Implementation ofMessageTypeResolverthat combines two resolvers in a fallback pattern.Indicates situations when access to the Payload of a Message is not allowed.Utility class to obtain resources used in previous versions of Axon Framework.Abstract implementation of aMessagethat delegates to an existing message.MessageDispatchInterceptor<M extends Message>Interceptor that allowsmessagesto be intercepted and modified before they are dispatched.MessageDispatchInterceptorChain<M extends Message>Marker interface for a handlers or components ofmessages.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 aMessageof typeMthrough a chain ofinterceptors, and ultimately to a message handler.MessageStream<M extends Message>MessageStream.Empty<M extends Message>AMessageStreamimplementation that completes normally or with an error without returning any elements.MessageStream.Entry<M extends Message>AMessageStream-specific container ofMessageimplementations.MessageStream.Single<M extends Message>AMessageStreamimplementation that returns at most a single result before completing.Utility methods to work withMessageStreams.Record combining aqualified nameandversion.Exception thrown when aMessageTypeResolveris unable to determine theMessageTypefor a given payload type.Functional interface describing a resolver fromMessage payloadto it'stype.Represents metadata that is passed along with a payload in aMessage.Utility methods to work with Project Reactor'smonos.Implementation of theMessageTypeResolverthat maintains a mapping of payload types to their correspondingMessageTypes.Builder interface for constructing aNamespaceMessageTypeResolver.Interface describing a qualifiedqualifiedName, providing space for anamespace,local qualifiedName.QueueMessageStream<M extends Message>MessageStream implementation that uses a Queue to make elements available to a consumer.Description of an Exception received from a remote source.Exception indicating that an error has occurred while remotely handling a message.Exception indicating that a non transient error has occurred while remotely handling a message.AMessagethat represents a result of handling some form of a request message.Implementation of theContextproviding a basic implementation for context-specific resource management.SimpleEntry<M extends Message>Simple implementation of theMessageStream.Entrycontaining a singleMessageimplementation of typeMand aContext.Simple implementation of theHandlerAttributeswhich is given theattributesin the constructor.Interface for a source ofEventMessagesto which event processors can subscribe.