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 |
Modifier and Type | Method and Description |
---|---|
<R> CommandResultMessage<R> |
CommandSerializer.deserialize(io.axoniq.axonserver.grpc.command.CommandResponse commandResponse)
Convert a
CommandResponse into a CommandResultMessage . |
Modifier and Type | Method and Description |
---|---|
io.axoniq.axonserver.grpc.command.CommandResponse |
CommandSerializer.serialize(CommandResultMessage<?> commandResultMessage,
String requestIdentifier)
Convert a
CommandResultMessage into a CommandProviderOutbound . |
Modifier and Type | Class and Description |
---|---|
class |
GenericCommandResultMessage<R>
Generic implementation of
CommandResultMessage . |
Modifier and Type | Method and Description |
---|---|
CommandResultMessage<R> |
CommandResultMessage.andMetaData(Map<String,?> metaData) |
static <T> CommandResultMessage<T> |
GenericCommandResultMessage.asCommandResultMessage(Object commandResult)
Returns the given
commandResult as a CommandResultMessage instance. |
static <T> CommandResultMessage<T> |
GenericCommandResultMessage.asCommandResultMessage(Throwable exception)
Creates a Command Result Message with the given
exception result. |
CommandResultMessage<R> |
CommandResultMessage.withMetaData(Map<String,?> metaData) |
Modifier and Type | Method and Description |
---|---|
void |
MonitorAwareCallback.onResult(CommandMessage<? extends C> commandMessage,
CommandResultMessage<? extends R> commandResultMessage) |
void |
CommandCallback.onResult(CommandMessage<? extends C> commandMessage,
CommandResultMessage<? extends R> commandResultMessage)
Invoked when command handling execution is completed.
|
Modifier and Type | Method and Description |
---|---|
CommandResultMessage<? extends R> |
FutureCallback.getResult()
Waits if necessary for the command handling to complete, and then returns its result.
|
CommandResultMessage<? extends R> |
FutureCallback.getResult(long timeout,
TimeUnit unit)
Waits if necessary for at most the given time for the command handling to complete, and then retrieves its
result, if available.
|
Modifier and Type | Method and Description |
---|---|
void |
NoOpCallback.onResult(CommandMessage<?> commandMessage,
CommandResultMessage<?> commandResultMessage)
Invoked when command handling execution is completed.
|
void |
FailureLoggingCallback.onResult(CommandMessage<? extends C> commandMessage,
CommandResultMessage<? extends R> commandResultMessage) |
void |
FutureCallback.onResult(CommandMessage<? extends C> commandMessage,
CommandResultMessage<? extends R> commandResultMessage) |
void |
LoggingCallback.onResult(CommandMessage message,
CommandResultMessage commandResultMessage) |
Modifier and Type | Method and Description |
---|---|
CommandResultMessage<?> |
ReplyMessage.getCommandResultMessage(Serializer serializer)
Returns a
CommandResultMessage containg the result of command processing. |
Modifier and Type | Method and Description |
---|---|
void |
CommandCallbackWrapper.onResult(CommandMessage<? extends C> message,
CommandResultMessage<? extends R> commandResultMessage) |
void |
CommandCallbackWrapper.reportResult(CommandResultMessage<R> result)
Invokes
CommandCallback.onResult(CommandMessage, CommandResultMessage) with given result on
the wrapped callback. |
Constructor and Description |
---|
ReplyMessage(String commandIdentifier,
CommandResultMessage<?> commandResultMessage,
Serializer serializer)
Initializes a ReplyMessage containing a reply to the command with given {commandIdentifier} and given
commandResultMessage . |
Modifier and Type | Method and Description |
---|---|
void |
RetryingCallback.onResult(CommandMessage<? extends C> commandMessage,
CommandResultMessage<? extends R> commandResultMessage) |
Modifier and Type | Method and Description |
---|---|
CommandResultMessage<?> |
CommandHandlingEntry.getResult()
Returns the result of the command's execution, or
null if the command is not yet executed or
resulted in an exception. |
Modifier and Type | Method and Description |
---|---|
void |
BlacklistDetectingCallback.onResult(CommandMessage<? extends C> commandMessage,
CommandResultMessage<? extends R> commandResultMessage) |
void |
CommandHandlingEntry.setResult(CommandResultMessage<?> result)
Registers the result of the command's execution, if successful.
|
Modifier and Type | Method and Description |
---|---|
ResultValidator<T> |
ResultValidator.expectResultMessage(CommandResultMessage<?> expectedResultMessage)
Expect the command handler to return the given
expectedResultMessage after execution. |
ResultValidator<T> |
ResultValidatorImpl.expectResultMessage(CommandResultMessage<?> expectedResultMessage) |
void |
ResultValidatorImpl.onResult(CommandMessage<?> commandMessage,
CommandResultMessage<?> commandResultMessage) |
Modifier and Type | Method and Description |
---|---|
ResultValidator<T> |
ResultValidator.expectResultMessageMatching(org.hamcrest.Matcher<? super CommandResultMessage<?>> matcher)
Expect the command handler to return a value that matches the given
matcher after execution. |
ResultValidator<T> |
ResultValidatorImpl.expectResultMessageMatching(org.hamcrest.Matcher<? super CommandResultMessage<?>> matcher) |
Copyright © 2010–2020. All rights reserved.