Package | Description |
---|---|
org.axonframework.commandhandling |
Classes that implement the concept of command handling using explicit command objects.
|
org.axonframework.commandhandling.disruptor | |
org.axonframework.commandhandling.distributed | |
org.axonframework.jgroups.commandhandling | |
org.axonframework.messaging |
Classes related to message processing in Axon Framework.
|
org.axonframework.queryhandling | |
org.axonframework.queryhandling.annotation | |
org.axonframework.spring.config | |
org.axonframework.springcloud.commandhandling | |
org.axonframework.test.aggregate | |
org.axonframework.test.utils |
A collection of classes which may prove useful when testing Axon-based classes.
|
Modifier and Type | Class and Description |
---|---|
class |
AggregateAnnotationCommandHandler<T>
Command handler that handles commands based on
CommandHandler
annotations on an aggregate. |
class |
AnnotationCommandHandlerAdapter
Adapter that turns any
@CommandHandler annotated bean into a MessageHandler implementation. |
Modifier and Type | Method and Description |
---|---|
protected <C,R> void |
SimpleCommandBus.handle(CommandMessage<C> command,
MessageHandler<? super CommandMessage<?>> handler,
CommandCallback<? super C,R> callback)
Performs the actual handling logic.
|
protected <C,R> void |
AsynchronousCommandBus.handle(CommandMessage<C> command,
MessageHandler<? super CommandMessage<?>> handler,
CommandCallback<? super C,R> callback) |
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 . |
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 | 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 |
---|---|
Registration |
JGroupsConnector.subscribe(String commandName,
MessageHandler<? super CommandMessage<?>> handler) |
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 | Method and Description |
---|---|
protected Map<org.axonframework.queryhandling.SimpleQueryBus.QueryDefinition,Collection<MessageHandler<? super QueryMessage<?,?>>>> |
SimpleQueryBus.getSubscriptions()
Returns the subscriptions for this query bus.
|
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,
Class<R> responseType,
MessageHandler<? super QueryMessage<?,R>> handler) |
<R> Registration |
QueryBus.subscribe(String queryName,
Class<R> responseType,
MessageHandler<? super QueryMessage<?,R>> handler)
Subscribe the given
handler to queries with the given queryName and responseName . |
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)
Sets the command handlers to subscribe to the bus.
|
Modifier and Type | Method and Description |
---|---|
Registration |
SpringHttpCommandBusConnector.subscribe(String commandName,
MessageHandler<? super CommandMessage<?>> handler) |
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 | 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–2017. All rights reserved.