| 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.distributed.jgroups | |
| org.axonframework.commandhandling.gateway | |
| org.axonframework.test |
Classes in support of testing Axon based applications.
|
| org.axonframework.test.utils |
A collection of classes which may prove useful when testing Axon-based classes.
|
| Modifier and Type | Method and Description |
|---|---|
<R> void |
SimpleCommandBus.dispatch(CommandMessage<?> command,
CommandCallback<R> callback) |
<R> void |
CommandBus.dispatch(CommandMessage<?> command,
CommandCallback<R> callback)
Dispatch the given
command to the CommandHandler subscribed to that type of command. |
protected <R> void |
SimpleCommandBus.doDispatch(CommandMessage<?> command,
CommandCallback<R> callback)
Performs the actual dispatching logic.
|
protected <R> void |
AsynchronousCommandBus.doDispatch(CommandMessage<?> command,
CommandCallback<R> callback) |
| Modifier and Type | Class and Description |
|---|---|
class |
FutureCallback<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
Abstract callback that can be extended when no result is expected from the command handler execution.
|
| Modifier and Type | Class and Description |
|---|---|
class |
BlacklistDetectingCallback<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 |
|---|---|
<R> void |
DisruptorCommandBus.dispatch(CommandMessage<?> command,
CommandCallback<R> callback) |
<R> void |
DisruptorCommandBus.doDispatch(CommandMessage command,
CommandCallback<R> callback)
Forces a dispatch of a command.
|
| Constructor and Description |
|---|
BlacklistDetectingCallback(CommandCallback<R> delegate,
CommandMessage command,
com.lmax.disruptor.RingBuffer<CommandHandlingEntry> ringBuffer,
DisruptorCommandBus commandBus,
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 | Method and Description |
|---|---|
<R> void |
DistributedCommandBus.dispatch(CommandMessage<?> command,
CommandCallback<R> callback)
Dispatch the given
command to the CommandHandler subscribed to that type of command. |
<R> void |
CommandBusConnector.send(String routingKey,
CommandMessage<?> command,
CommandCallback<R> callback)
Sends the given
command to the node assigned to handle messages with the given
routingKey. |
| Modifier and Type | Method and Description |
|---|---|
<R> void |
JGroupsConnector.send(String routingKey,
CommandMessage<?> commandMessage,
CommandCallback<R> callback) |
| Modifier and Type | Class and Description |
|---|---|
class |
RetryingCallback<R>
Callback implementation that will invoke a retry scheduler if a command results in a runtime exception.
|
| Modifier and Type | Method and Description |
|---|---|
<R> GatewayProxyFactory |
GatewayProxyFactory.registerCommandCallback(CommandCallback<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. |
<R> void |
DefaultCommandGateway.send(Object command,
CommandCallback<R> callback) |
<R> void |
CommandGateway.send(Object command,
CommandCallback<R> callback)
Sends the given
command, and have the result of the command's execution reported to the given
callback. |
protected <R> void |
AbstractCommandGateway.send(Object command,
CommandCallback<R> callback)
Sends the given
command, and invokes the callback when the command is processed. |
| 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. |
| Constructor and Description |
|---|
RetryingCallback(CommandCallback<R> delegate,
CommandMessage commandMessage,
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 | Class and Description |
|---|---|
class |
ResultValidatorImpl
Implementation of the ResultValidator.
|
| Modifier and Type | Method and Description |
|---|---|
<R> void |
RecordingCommandBus.dispatch(CommandMessage<?> command,
CommandCallback<R> callback) |
Copyright © 2010-2014. All Rights Reserved.