| Package | Description | 
|---|---|
| org.axonframework.commandhandling | 
 Classes that implement the concept of command handling using explicit command objects. 
 | 
| org.axonframework.commandhandling.callbacks | |
| org.axonframework.commandhandling.disruptor | |
| org.axonframework.commandhandling.distributed | |
| org.axonframework.commandhandling.gateway | |
| org.axonframework.jgroups.commandhandling | |
| org.axonframework.spring.commandhandling.gateway | |
| 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  | 
MonitorAwareCallback<C,R>
Wrapper for a callback that notifies a Message Monitor of the message execution result. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
<C,R> void | 
SimpleCommandBus.dispatch(CommandMessage<C> command,
        CommandCallback<? super C,R> callback)  | 
<C,R> void | 
CommandBus.dispatch(CommandMessage<C> command,
        CommandCallback<? super C,R> callback)
Dispatch the given  
command to the CommandHandler subscribed to the given command's name. | 
protected <C,R> void | 
SimpleCommandBus.doDispatch(CommandMessage<C> command,
          CommandCallback<? super C,R> callback)
Performs the actual dispatching logic. 
 | 
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)  | 
| Constructor and Description | 
|---|
MonitorAwareCallback(CommandCallback<C,R> delegate,
                    MessageMonitor.MonitorCallback messageMonitorCallback)
Initialize a callback wrapped around the  
delegate which will notify a Message Monitor for the given messageMonitorCallback. | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
FailureLoggingCallback<C,R>
A  
CommandCallback implementation wrapping another, that concisely logs failed commands. | 
class  | 
FutureCallback<C,R>
Command Handler Callback that allows the dispatching thread to wait for the result of the callback, using the Future
 mechanism. 
 | 
class  | 
LoggingCallback
CommandCallback implementation that simply logs the results of a command. 
 | 
class  | 
NoOpCallback
Callback that does absolutely nothing when invoked. 
 | 
class  | 
VoidCallback<C>
Abstract callback that can be extended when no result is expected from the command handler execution. 
 | 
| Constructor and Description | 
|---|
FailureLoggingCallback(CommandCallback<C,R> delegate)
Initialize the callback to delegate calls to the given  
delegate, logging failures on a logger
 for this class (on warn level). | 
FailureLoggingCallback(org.slf4j.Logger logger,
                      CommandCallback<C,R> delegate)
Initialize the callback to delegate calls to the given  
delegate, logging failures on the given
 logger (on warn level). | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
BlacklistDetectingCallback<C,R>
Wrapper for command handler Callbacks that detects blacklisted aggregates and starts a cleanup process when an
 aggregate is blacklisted. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
<C,R> void | 
DisruptorCommandBus.dispatch(CommandMessage<C> command,
        CommandCallback<? super C,R> callback)  | 
| Constructor and Description | 
|---|
BlacklistDetectingCallback(CommandCallback<? super C,R> delegate,
                          com.lmax.disruptor.RingBuffer<CommandHandlingEntry> ringBuffer,
                          BiConsumer<CommandMessage<? extends C>,CommandCallback<? super C,R>> retryMethod,
                          boolean rescheduleOnCorruptState)
Initializes the callback which allows the given  
command to be rescheduled on the given
 ringBuffer if it failed due to a corrupt state. | 
| Constructor and Description | 
|---|
BlacklistDetectingCallback(CommandCallback<? super C,R> delegate,
                          com.lmax.disruptor.RingBuffer<CommandHandlingEntry> ringBuffer,
                          BiConsumer<CommandMessage<? extends C>,CommandCallback<? super C,R>> retryMethod,
                          boolean rescheduleOnCorruptState)
Initializes the callback which allows the given  
command to be rescheduled on the given
 ringBuffer if it failed due to a corrupt state. | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
CommandCallbackWrapper<A,C,R>
Wrapper for a Command callback. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
<C,R> void | 
DistributedCommandBus.dispatch(CommandMessage<C> command,
        CommandCallback<? super C,R> callback)
Dispatch the given  
command to the CommandHandler subscribed to the given command's name. | 
<C,R> void | 
CommandBusConnector.send(Member destination,
    CommandMessage<C> command,
    CommandCallback<? super C,R> callback)
Sends the given  
command to the node assigned to handle messages with the given
 routingKey. | 
| Constructor and Description | 
|---|
CommandCallbackWrapper(A channelId,
                      CommandMessage<C> message,
                      CommandCallback<? super C,R> callback)
Initializes a  
CommandCallbackWrapper which wraps the original callback and holds on to the
 command message and channelId of the channel on which the message is sent. | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
RetryingCallback<C,R>
Callback implementation that will invoke a retry scheduler if a command results in a runtime exception. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
<C,R> CommandGatewayFactory | 
CommandGatewayFactory.registerCommandCallback(CommandCallback<C,R> callback)
Registers the  
callback, which is invoked for each sent command, unless Axon is able to detect that
 the result of the command does not match the type accepted by the callback. | 
<C,R> void | 
DefaultCommandGateway.send(C command,
    CommandCallback<? super C,R> callback)  | 
<C,R> void | 
CommandGateway.send(C command,
    CommandCallback<? super C,R> callback)
Sends the given  
command, and have the result of the command's execution reported to the given
 callback. | 
protected <C,R> void | 
AbstractCommandGateway.send(C command,
    CommandCallback<? super C,R> callback)
Sends the given  
command, and invokes the callback when the command is processed. | 
| Constructor and Description | 
|---|
RetryingCallback(CommandCallback<C,R> delegate,
                RetryScheduler retryScheduler,
                CommandBus commandBus)
Initialize the RetryingCallback with the given  
delegate, representing the actual callback passed as
 a parameter to dispatch, the given commandMessage, retryScheduler and
 commandBus. | 
| Modifier and Type | Method and Description | 
|---|---|
<C,R> void | 
JGroupsConnector.send(Member destination,
    CommandMessage<C> command,
    CommandCallback<? super C,R> callback)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
CommandGatewayFactoryBean.setCommandCallbacks(List<CommandCallback<?,?>> commandCallbacks)
Registers the  
commandCallbacks, which are invoked for each sent command, unless Axon is able to
 detect
 that the result of the command does not match the type accepted by that callback. | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
SpringHttpCommandBusConnector.SpringHttpReplyFutureCallback<C,R>  | 
| Modifier and Type | Method and Description | 
|---|---|
<C,R> void | 
SpringHttpCommandBusConnector.send(Member destination,
    CommandMessage<C> commandMessage,
    CommandCallback<? super C,R> callback)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
ResultValidatorImpl
Implementation of the ResultValidator. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
<C,R> void | 
RecordingCommandBus.dispatch(CommandMessage<C> command,
        CommandCallback<? super C,R> callback)  | 
Copyright © 2010–2018. All rights reserved.