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<T>
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.