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.