| Package | Description |
|---|---|
| org.axonframework.axonserver.connector.command | |
| org.axonframework.commandhandling |
Classes that implement the concept of command handling using explicit command objects.
|
| org.axonframework.commandhandling.callbacks | |
| org.axonframework.commandhandling.distributed | |
| org.axonframework.commandhandling.gateway | |
| org.axonframework.disruptor.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 | Method and Description |
|---|---|
<C,R> void |
AxonServerCommandBus.dispatch(CommandMessage<C> commandMessage,
CommandCallback<? super C,? super R> commandCallback) |
| 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 |
CommandBus.dispatch(CommandMessage<C> command,
CommandCallback<? super C,? super R> callback)
Dispatch the given
command to the CommandHandler subscribed to the given command's name. |
<C,R> void |
SimpleCommandBus.dispatch(CommandMessage<C> command,
CommandCallback<? super C,? super R> callback) |
protected <C,R> void |
SimpleCommandBus.doDispatch(CommandMessage<C> command,
CommandCallback<? super C,? super R> callback)
Performs the actual dispatching logic.
|
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) |
| 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.
|
| 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 |
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,? super 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,? super 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,
ResponseType<R> responseType)
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,? super R> callback) |
<C,R> void |
CommandGateway.send(C command,
CommandCallback<? super C,? super 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,? super 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 | 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,? super 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 |
ResultValidatorImpl<T>
Implementation of the ResultValidator.
|
| Modifier and Type | Method and Description |
|---|---|
<C,R> void |
RecordingCommandBus.dispatch(CommandMessage<C> command,
CommandCallback<? super C,? super R> callback) |
Copyright © 2010–2018. All rights reserved.