Package | Description |
---|---|
org.axonframework.axonserver.connector.command | |
org.axonframework.axonserver.connector.query | |
org.axonframework.commandhandling |
Classes that implement the concept of command handling using explicit command objects.
|
org.axonframework.commandhandling.distributed | |
org.axonframework.disruptor.commandhandling | |
org.axonframework.eventhandling |
Classes related to event handling and dispatching, such as
Event Listeners and the Event Bus . |
org.axonframework.messaging |
Classes related to message processing in Axon Framework.
|
org.axonframework.modelling.command | |
org.axonframework.modelling.saga | |
org.axonframework.queryhandling | |
org.axonframework.queryhandling.annotation | |
org.axonframework.spring.config | |
org.axonframework.test.aggregate | |
org.axonframework.test.saga | |
org.axonframework.test.utils |
A collection of classes which may prove useful when testing Axon-based classes.
|
Modifier and Type | Method and Description |
---|---|
Registration |
AxonServerCommandBus.subscribe(String commandName,
MessageHandler<? super CommandMessage<?>> messageHandler) |
Modifier and Type | Method and Description |
---|---|
<R> Registration |
AxonServerQueryBus.subscribe(String queryName,
Type responseType,
MessageHandler<? super QueryMessage<?,R>> handler) |
Modifier and Type | Interface and Description |
---|---|
interface |
CommandMessageHandler
MessageHandler specialization for handlers of Command Messages.
|
Modifier and Type | Class and Description |
---|---|
class |
AnnotationCommandHandlerAdapter<T>
Adapter that turns any
@CommandHandler annotated bean into a MessageHandler
implementation. |
Modifier and Type | Method and Description |
---|---|
MessageHandler<? super CommandMessage<?>> |
LoggingDuplicateCommandHandlerResolver.resolve(String commandName,
MessageHandler<? super CommandMessage<?>> registeredHandler,
MessageHandler<? super CommandMessage<?>> candidateHandler) |
MessageHandler<? super CommandMessage<?>> |
FailingDuplicateCommandHandlerResolver.resolve(String commandName,
MessageHandler<? super CommandMessage<?>> registeredHandler,
MessageHandler<? super CommandMessage<?>> candidateHandler) |
MessageHandler<? super CommandMessage<?>> |
DuplicateCommandHandlerResolver.resolve(String commandName,
MessageHandler<? super CommandMessage<?>> registeredHandler,
MessageHandler<? super CommandMessage<?>> candidateHandler)
Chooses what to do when a duplicate handler is registered, returning the handler that should be selected for
command handling, or otherwise throwing an exception to reject registration altogether.
|
Modifier and Type | Method and Description |
---|---|
protected <C,R> void |
SimpleCommandBus.handle(CommandMessage<C> command,
MessageHandler<? super CommandMessage<?>> handler,
CommandCallback<? super C,? super R> callback)
Performs the actual handling logic.
|
protected <C,R> void |
AsynchronousCommandBus.handle(CommandMessage<C> command,
MessageHandler<? super CommandMessage<?>> handler,
CommandCallback<? super C,? super R> callback) |
MessageHandler<? super CommandMessage<?>> |
LoggingDuplicateCommandHandlerResolver.resolve(String commandName,
MessageHandler<? super CommandMessage<?>> registeredHandler,
MessageHandler<? super CommandMessage<?>> candidateHandler) |
MessageHandler<? super CommandMessage<?>> |
LoggingDuplicateCommandHandlerResolver.resolve(String commandName,
MessageHandler<? super CommandMessage<?>> registeredHandler,
MessageHandler<? super CommandMessage<?>> candidateHandler) |
MessageHandler<? super CommandMessage<?>> |
FailingDuplicateCommandHandlerResolver.resolve(String commandName,
MessageHandler<? super CommandMessage<?>> registeredHandler,
MessageHandler<? super CommandMessage<?>> candidateHandler) |
MessageHandler<? super CommandMessage<?>> |
FailingDuplicateCommandHandlerResolver.resolve(String commandName,
MessageHandler<? super CommandMessage<?>> registeredHandler,
MessageHandler<? super CommandMessage<?>> candidateHandler) |
MessageHandler<? super CommandMessage<?>> |
DuplicateCommandHandlerResolver.resolve(String commandName,
MessageHandler<? super CommandMessage<?>> registeredHandler,
MessageHandler<? super CommandMessage<?>> candidateHandler)
Chooses what to do when a duplicate handler is registered, returning the handler that should be selected for
command handling, or otherwise throwing an exception to reject registration altogether.
|
MessageHandler<? super CommandMessage<?>> |
DuplicateCommandHandlerResolver.resolve(String commandName,
MessageHandler<? super CommandMessage<?>> registeredHandler,
MessageHandler<? super CommandMessage<?>> candidateHandler)
Chooses what to do when a duplicate handler is registered, returning the handler that should be selected for
command handling, or otherwise throwing an exception to reject registration altogether.
|
Registration |
SimpleCommandBus.subscribe(String commandName,
MessageHandler<? super CommandMessage<?>> handler)
Subscribe the given
handler to commands with given commandName . |
Registration |
CommandBus.subscribe(String commandName,
MessageHandler<? super CommandMessage<?>> handler)
Subscribe the given
handler to commands with the given commandName . |
Constructor and Description |
---|
DuplicateCommandHandlerSubscriptionException(String commandName,
MessageHandler<? super CommandMessage<?>> initialHandler,
MessageHandler<? super CommandMessage<?>> duplicateHandler)
Initialize a duplicate command handler subscription exception using the given
initialHandler and duplicateHandler to form a specific message. |
DuplicateCommandHandlerSubscriptionException(String commandName,
MessageHandler<? super CommandMessage<?>> initialHandler,
MessageHandler<? super CommandMessage<?>> duplicateHandler)
Initialize a duplicate command handler subscription exception using the given
initialHandler and duplicateHandler to form a specific message. |
Modifier and Type | Method and Description |
---|---|
Registration |
DistributedCommandBus.subscribe(String commandName,
MessageHandler<? super CommandMessage<?>> handler)
Subscribe the given
handler to commands with the given commandName . |
Registration |
CommandBusConnector.subscribe(String commandName,
MessageHandler<? super CommandMessage<?>> handler)
Subscribes a command message handler for commands with given
commandName . |
Modifier and Type | Method and Description |
---|---|
void |
CommandHandlingEntry.reset(CommandMessage<?> newCommand,
MessageHandler<? super CommandMessage<?>> newCommandHandler,
int newInvokerSegmentId,
int newPublisherSegmentId,
BlacklistDetectingCallback<?,?> newCallback,
List<MessageHandlerInterceptor<? super CommandMessage<?>>> invokerInterceptors,
List<MessageHandlerInterceptor<? super CommandMessage<?>>> publisherInterceptors)
Resets this entry, preparing it for use for another command.
|
Registration |
DisruptorCommandBus.subscribe(String commandName,
MessageHandler<? super CommandMessage<?>> handler) |
Modifier and Type | Interface and Description |
---|---|
interface |
EventMessageHandler
Interface to be implemented by classes that can handle events.
|
Modifier and Type | Class and Description |
---|---|
class |
AnnotationEventHandlerAdapter
Adapter that turns any bean with
EventHandler annotated methods into an EventMessageHandler . |
Constructor and Description |
---|
DefaultInterceptorChain(UnitOfWork<? extends T> unitOfWork,
Iterable<? extends MessageHandlerInterceptor<? super T>> interceptors,
MessageHandler<? super T> handler)
Initialize the default interceptor chain to dispatch the given
message , through the
chain , to the handler . |
Modifier and Type | Class and Description |
---|---|
class |
AggregateAnnotationCommandHandler<T>
Command handler that registers a set of
CommandHandler based on annotations of an aggregate. |
Modifier and Type | Interface and Description |
---|---|
interface |
Saga<T>
Interface describing an implementation of a Saga.
|
Modifier and Type | Class and Description |
---|---|
class |
AnnotatedSaga<T>
Implementation of the
interface that allows for a POJO instance with annotated message handlers to act
as a Saga. |
Modifier and Type | Method and Description |
---|---|
MessageHandler<? super QueryMessage<?,R>> |
QuerySubscription.getQueryHandler()
Retrieve the query handler of this subscription as a
MessageHandler . |
Modifier and Type | Method and Description |
---|---|
void |
QueryInvocationErrorHandler.onError(Throwable error,
QueryMessage<?,?> queryMessage,
MessageHandler messageHandler)
Invoked when an error occurred while invoking a message handler in a scatter-gather query.
|
void |
LoggingQueryInvocationErrorHandler.onError(Throwable error,
QueryMessage<?,?> queryMessage,
MessageHandler messageHandler) |
<R> Registration |
SimpleQueryBus.subscribe(String queryName,
Type responseType,
MessageHandler<? super QueryMessage<?,R>> handler) |
<R> Registration |
QueryBus.subscribe(String queryName,
Type responseType,
MessageHandler<? super QueryMessage<?,R>> handler)
Subscribe the given
handler to queries with the given queryName and responseType . |
Constructor and Description |
---|
QuerySubscription(Type responseType,
MessageHandler<? super QueryMessage<?,R>> queryHandler)
|
Modifier and Type | Class and Description |
---|---|
class |
AnnotationQueryHandlerAdapter<T>
Adapter that turns any
@QueryHandler annotated bean into a MessageHandler
implementation. |
Modifier and Type | Method and Description |
---|---|
void |
CommandHandlerSubscriber.setCommandHandlers(Collection<MessageHandler> commandHandlers)
Deprecated.
Sets the command handlers to subscribe to the bus.
|
Modifier and Type | Method and Description |
---|---|
FixtureConfiguration<T> |
FixtureConfiguration.registerCommandHandler(Class<?> payloadType,
MessageHandler<CommandMessage<?>> commandHandler)
Registers a
commandHandler to handle commands of the given commandType with the
command bus used by this fixture. |
FixtureConfiguration<T> |
AggregateTestFixture.registerCommandHandler(Class<?> payloadType,
MessageHandler<CommandMessage<?>> commandHandler) |
FixtureConfiguration<T> |
FixtureConfiguration.registerCommandHandler(String commandName,
MessageHandler<CommandMessage<?>> commandHandler)
Registers a
commandHandler to handle commands of the given commandType with the
command bus used by this fixture. |
FixtureConfiguration<T> |
AggregateTestFixture.registerCommandHandler(String commandName,
MessageHandler<CommandMessage<?>> commandHandler) |
Modifier and Type | Class and Description |
---|---|
class |
EventValidator
Helper class for validating events published on a given EventBus.
|
Modifier and Type | Method and Description |
---|---|
Map<String,MessageHandler<? super CommandMessage<?>>> |
RecordingCommandBus.getSubscriptions()
Returns a Map will all Command Names and their Command Handler that have been subscribed to this command bus.
|
Modifier and Type | Method and Description |
---|---|
boolean |
RecordingCommandBus.isSubscribed(MessageHandler<? super CommandMessage<?>> commandHandler)
Indicates whether the given
commandHandler is subscribed to this command bus. |
<C> boolean |
RecordingCommandBus.isSubscribed(String commandName,
MessageHandler<? super CommandMessage<?>> commandHandler)
Indicates whether the given
commandHandler is subscribed to commands of the given
commandType on this command bus. |
Registration |
RecordingCommandBus.subscribe(String commandName,
MessageHandler<? super CommandMessage<?>> handler) |
Copyright © 2010–2024. All rights reserved.