| 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 |
|---|---|
AxonServerCommandBus.Builder |
AxonServerCommandBus.Builder.defaultCommandCallback(CommandCallback<Object,Object> defaultCommandCallback)
Sets the callback to use when commands are dispatched in a "fire and forget" method, such as
AxonServerCommandBus.dispatch(CommandMessage). |
<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.
|
class |
WrappedCommandCallback<C,R>
Represents a
CommandCallback that was wrapped with another. |
| Modifier and Type | Method and Description |
|---|---|
default CommandCallback<C,R> |
CommandCallback.wrap(CommandCallback<C,R> wrappingCallback)
Wraps the command callback with another using a
WrappedCommandCallback. |
| Modifier and Type | Method and Description |
|---|---|
SimpleCommandBus.Builder |
SimpleCommandBus.Builder.defaultCommandCallback(CommandCallback<Object,Object> defaultCommandCallback)
Sets the callback to use when commands are dispatched in a "fire and forget" method, such as
SimpleCommandBus.dispatch(CommandMessage). |
AsynchronousCommandBus.Builder |
AsynchronousCommandBus.Builder.defaultCommandCallback(CommandCallback<Object,Object> defaultCommandCallback) |
<C,R> void |
SimpleCommandBus.dispatch(CommandMessage<C> command,
CommandCallback<? super C,? super R> callback) |
<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. |
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) |
default CommandCallback<C,R> |
CommandCallback.wrap(CommandCallback<C,R> wrappingCallback)
Wraps the command callback with another using a
WrappedCommandCallback. |
| 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. |
WrappedCommandCallback(CommandCallback<C,R> outerCallback,
CommandCallback<C,R> innerCallback)
Constructs a new
WrappedCommandCallback, called by using wrap(CommandCallback). |
WrappedCommandCallback(CommandCallback<C,R> outerCallback,
CommandCallback<C,R> innerCallback)
Constructs a new
WrappedCommandCallback, called by using wrap(CommandCallback). |
| 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)
Deprecated.
Please use
wrap(CommandCallback) to wrap a command with a delegate and use
the FailureLoggingCallback(org.slf4j.Logger, org.axonframework.commandhandling.CommandCallback<C, R>) to create this callback |
FailureLoggingCallback(org.slf4j.Logger logger,
CommandCallback<C,R> delegate)
Deprecated.
Please use
wrap(CommandCallback) to wrap a command with a delegate and use
the FailureLoggingCallback(Logger) to specify you custom logger. |
| Modifier and Type | Class and Description |
|---|---|
class |
CommandCallbackWrapper<A,C,R>
Wrapper for a Command callback.
|
| Modifier and Type | Method and Description |
|---|---|
DistributedCommandBus.Builder |
DistributedCommandBus.Builder.defaultCommandCallback(CommandCallback<Object,Object> defaultCommandCallback)
Sets the callback to use when commands are dispatched in a "fire and forget" method, such as
DistributedCommandBus.dispatch(CommandMessage). |
<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 |
|---|---|
DefaultCommandGateway.Builder |
DefaultCommandGateway.Builder.commandCallback(CommandCallback<Object,Object> commandCallback)
Set a
CommandCallback on the command bus. |
<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 |
|---|---|
DisruptorCommandBus.Builder |
DisruptorCommandBus.Builder.defaultCommandCallback(CommandCallback<Object,Object> defaultCommandCallback)
Sets the callback to use when commands are dispatched in a "fire and forget" method, such as
DisruptorCommandBus.dispatch(CommandMessage). |
<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–2025. All rights reserved.