Package org.axonframework.messaging
package org.axonframework.messaging
Classes related to message processing in Axon Framework.
-
ClassDescriptionAbstract base class for Messages.DefaultInterceptorChain<T extends Message<?>>Mechanism that takes care of interceptor and handler execution.Distributed<MessageBus>A contract towards being a distributed message bus implementation.Exception indication that an error occurred while publishing an event to an AMQP BrokerException thrown to indicate that execution of a task has failed.Generic implementation of a
Messagethat contains the payload and metadata as unserialized values.Generic implementation ofResultMessage.Container for message handler attributes.Base exception for exceptions raised by Handler methods.Default headers to include when publishing a message on a broker.Indicates situations when access to the Payload of a Message is not allowed.The interceptor chain manages the flow of a message through a chain of interceptors and ultimately to the message handler.Message<T>Representation of a Message, containing a Payload and MetaData.Abstract implementation of aMessagethat delegates to an existing message.MessageDispatchInterceptor<T extends Message<?>>Interceptor that allows messages to be intercepted and modified before they are dispatched.MessageDispatchInterceptorSupport<T extends Message<?>>Interface marking components capable of registering Dispatch Interceptors.MessageHandler<T extends Message<?>>Interface for a component that processes Messages.MessageHandlerInterceptor<T extends Message<?>>Workflow interface that allows for customized message handler invocation chains.MessageHandlerInterceptorSupport<T extends Message<?>>Interface marking components capable of registering Handler Interceptors.Represents MetaData that is passed along with a payload in a Message.AScopeDescriptordescribing no active scope.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.Message that represents a result of handling some form of request message.Describes functionality off processes which can be 'in scope', like an Aggregate or Saga.Interface describing components which areScopeaware.Contract towards a mechanism to provide aStreamof components which areScopeAware.Denotes the description of aScope.Simple implementation of theHandlerAttributeswhich is given theattributesin the constructor.StreamableMessageSource<M extends Message<?>>Interface for a source ofmessagesthat processors can track.SubscribableMessageSource<M extends Message<?>>Interface for a source ofmessagesto which message processors can subscribe.