Uses of Interface
org.axonframework.commandhandling.CommandMessage

Packages that use CommandMessage

org.axonframework.auditing
org.axonframework.commandhandling	Classes that implement the concept of command handling using explicit command objects.
org.axonframework.commandhandling.annotation	Classes that provide annotation support for command handling.
org.axonframework.commandhandling.callbacks
org.axonframework.commandhandling.disruptor
org.axonframework.commandhandling.distributed
org.axonframework.commandhandling.distributed.jgroups
org.axonframework.commandhandling.distributed.jgroups.support.callbacks
org.axonframework.commandhandling.gateway
org.axonframework.commandhandling.interceptors	Contains some useful implementations of interceptors that many application can benefit from.
org.axonframework.quickstart.handler
org.axonframework.test.utils	A collection of classes which may prove useful when testing Axon-based classes.

Uses of CommandMessage in org.axonframework.auditing

Methods in org.axonframework.auditing with parameters of type CommandMessage

Object	AuditingInterceptor.handle(CommandMessage<?> command, UnitOfWork unitOfWork, InterceptorChain chain)
void	NullAuditLogger.logFailed(CommandMessage<?> command, Throwable failureCause, List<EventMessage> events) Writes a failure entry to the audit logs.
void	AuditLogger.logFailed(CommandMessage<?> command, Throwable failureCause, List<EventMessage> events) Writes a failure entry to the audit logs.
void	NullAuditLogger.logSuccessful(CommandMessage<?> command, Object returnValue, List<EventMessage> events) Writes a success entry to the audit logs.
void	AuditLogger.logSuccessful(CommandMessage<?> command, Object returnValue, List<EventMessage> events) Writes a success entry to the audit logs.
Map<String,Object>	EmptyDataProvider.provideAuditDataFor(CommandMessage<?> command) Return the relevant auditing information for the given command.
Map<String,Object>	CorrelationAuditDataProvider.provideAuditDataFor(CommandMessage<?> command)
Map<String,Object>	CommandMetaDataProvider.provideAuditDataFor(CommandMessage<?> command)
Map<String,Object>	AuditDataProvider.provideAuditDataFor(CommandMessage<?> command) Return the relevant auditing information for the given command.

Constructors in org.axonframework.auditing with parameters of type CommandMessage

AuditingUnitOfWorkListener(CommandMessage<?> command, AuditDataProvider auditDataProvider, AuditLogger auditLogger)
Initialize a listener for the given command.

Uses of CommandMessage in org.axonframework.commandhandling

Classes in org.axonframework.commandhandling that implement CommandMessage

class

GenericCommandMessage<T> Implementation of the CommandMessage that takes all properties as constructor parameters.

Methods in org.axonframework.commandhandling that return CommandMessage

CommandMessage<T>	CommandMessage.andMetaData(Map<String,?> metaData) Returns a copy of this CommandMessage with it MetaData merged with the given metaData.
static CommandMessage	GenericCommandMessage.asCommandMessage(Object command) Returns the given command as a CommandMessage.
CommandMessage<?>	CommandDispatchInterceptor.handle(CommandMessage<?> commandMessage) Invoked each time a command is about to be dispatched on a Command Bus.
protected CommandMessage<?>	SimpleCommandBus.intercept(CommandMessage<?> command) Invokes all the dispatch interceptors.
CommandMessage<T>	CommandMessage.withMetaData(Map<String,?> metaData) Returns a copy of this CommandMessage with the given metaData.

Methods in org.axonframework.commandhandling with parameters of type CommandMessage

void	SimpleCommandBus.dispatch(CommandMessage<?> command)
void	CommandBus.dispatch(CommandMessage<?> command) Dispatch the given command to the CommandHandler subscribed to that type of command.
<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)
CommandMessage<?>	CommandDispatchInterceptor.handle(CommandMessage<?> commandMessage) Invoked each time a command is about to be dispatched on a Command Bus.
Object	CommandHandlerInterceptor.handle(CommandMessage<?> commandMessage, UnitOfWork unitOfWork, InterceptorChain interceptorChain) The handle method is invoked each time a command is dispatched through the command bus that the CommandHandlerInterceptor is declared on.
Object	CommandHandler.handle(CommandMessage<T> commandMessage, UnitOfWork unitOfWork) Handles the given command.
protected CommandMessage<?>	SimpleCommandBus.intercept(CommandMessage<?> command) Invokes all the dispatch interceptors.
Object	InterceptorChain.proceed(CommandMessage<?> command) Signals the Interceptor Chain to continue processing the given command.
Object	DefaultInterceptorChain.proceed(CommandMessage<?> commandProceedWith) Signals the Interceptor Chain to continue processing the given command.
VersionedAggregateIdentifier	MetaDataCommandTargetResolver.resolveTarget(CommandMessage<?> command)
VersionedAggregateIdentifier	CommandTargetResolver.resolveTarget(CommandMessage<?> command) Returns the Aggregate Identifier and optionally the expected version of the aggregate on which the given command should be executed.

Constructors in org.axonframework.commandhandling with parameters of type CommandMessage

DefaultInterceptorChain(CommandMessage<?> command, UnitOfWork unitOfWork, CommandHandler<?> handler, Iterable<? extends CommandHandlerInterceptor> chain)
Initialize the default interceptor chain to dispatch the given command, through the chain, to the handler.

Uses of CommandMessage in org.axonframework.commandhandling.annotation

Methods in org.axonframework.commandhandling.annotation with parameters of type CommandMessage

Object	AnnotationCommandHandlerAdapter.handle(CommandMessage<Object> command, UnitOfWork unitOfWork) Invokes the @CommandHandler annotated method that accepts the given command.
Object	AggregateAnnotationCommandHandler.handle(CommandMessage<Object> commandMessage, UnitOfWork unitOfWork)
protected Object	AggregateAnnotationCommandHandler.resolveReturnValue(CommandMessage<?> command, T createdAggregate) Resolves the value to return when the given command has created the given aggregate.
VersionedAggregateIdentifier	AnnotationCommandTargetResolver.resolveTarget(CommandMessage<?> command)

Uses of CommandMessage in org.axonframework.commandhandling.callbacks

Constructors in org.axonframework.commandhandling.callbacks with parameters of type CommandMessage

LoggingCallback(CommandMessage<?> message)
Initialize a LoggingCallback for the given message.

Uses of CommandMessage in org.axonframework.commandhandling.disruptor

Methods in org.axonframework.commandhandling.disruptor that return CommandMessage

CommandMessage<?>

CommandHandlingEntry.getCommand() Returns the CommandMessage to be executed.

Methods in org.axonframework.commandhandling.disruptor with parameters of type CommandMessage

void	DisruptorCommandBus.dispatch(CommandMessage<?> command)
<R> void	DisruptorCommandBus.dispatch(CommandMessage<?> command, CommandCallback<R> callback)
<R> void	DisruptorCommandBus.doDispatch(CommandMessage command, CommandCallback<R> callback) Forces a dispatch of a command.
void	CommandHandlingEntry.reset(CommandMessage<?> newCommand, CommandHandler newCommandHandler, int newInvokerSegmentId, int newPublisherSegmentId, int newSerializerSegmentId, BlacklistDetectingCallback newCallback, List<CommandHandlerInterceptor> invokerInterceptors, List<CommandHandlerInterceptor> publisherInterceptors) Resets this entry, preparing it for use for another command.

Constructors in org.axonframework.commandhandling.disruptor with parameters of type CommandMessage

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.

Uses of CommandMessage in org.axonframework.commandhandling.distributed

Methods in org.axonframework.commandhandling.distributed with parameters of type CommandMessage

void	DistributedCommandBus.dispatch(CommandMessage<?> command) Dispatch the given command to the CommandHandler subscribed to that type of command.
<R> void	DistributedCommandBus.dispatch(CommandMessage<?> command, CommandCallback<R> callback) Dispatch the given command to the CommandHandler subscribed to that type of command.
protected String	MetaDataRoutingStrategy.doResolveRoutingKey(CommandMessage<?> command)
protected String	AnnotationRoutingStrategy.doResolveRoutingKey(CommandMessage<?> command)
protected abstract String	AbstractRoutingStrategy.doResolveRoutingKey(CommandMessage<?> command) Resolve the Routing Key for the given command.
String	RoutingStrategy.getRoutingKey(CommandMessage<?> command) Generates a routing key for the given command.
String	AbstractRoutingStrategy.getRoutingKey(CommandMessage<?> command)
void	CommandBusConnector.send(String routingKey, CommandMessage<?> command) Sends the given command to the node assigned to handle messages with the given routingKey.
<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.

Uses of CommandMessage in org.axonframework.commandhandling.distributed.jgroups

Methods in org.axonframework.commandhandling.distributed.jgroups that return CommandMessage

CommandMessage<?>

DispatchMessage.getCommandMessage(Serializer serializer) Returns the CommandMessage wrapped in this Message.

Methods in org.axonframework.commandhandling.distributed.jgroups with parameters of type CommandMessage

void	JGroupsConnector.send(String routingKey, CommandMessage<?> commandMessage)
<R> void	JGroupsConnector.send(String routingKey, CommandMessage<?> commandMessage, CommandCallback<R> callback)

Constructors in org.axonframework.commandhandling.distributed.jgroups with parameters of type CommandMessage

DispatchMessage(CommandMessage<?> commandMessage, Serializer serializer, boolean expectReply)
Initialized a DispatchMessage for the given commandMessage, to be serialized using given serializer.

Uses of CommandMessage in org.axonframework.commandhandling.distributed.jgroups.support.callbacks

Constructors in org.axonframework.commandhandling.distributed.jgroups.support.callbacks with parameters of type CommandMessage

ReplyingCallback(org.jgroups.JChannel channel, org.jgroups.Address address, CommandMessage commandMessage, Serializer serializer)
Initialize the callback to send a reply for an incoming commandMessage to given address using the given channel.

Uses of CommandMessage in org.axonframework.commandhandling.gateway

Methods in org.axonframework.commandhandling.gateway that return CommandMessage

protected CommandMessage

AbstractCommandGateway.processInterceptors(CommandMessage commandMessage) Invokes all the dispatch interceptors and returns the CommandMessage instance that should be dispatched.

Methods in org.axonframework.commandhandling.gateway with parameters of type CommandMessage

protected CommandMessage	AbstractCommandGateway.processInterceptors(CommandMessage commandMessage) Invokes all the dispatch interceptors and returns the CommandMessage instance that should be dispatched.
boolean	RetryScheduler.scheduleRetry(CommandMessage commandMessage, RuntimeException lastFailure, List<Class<? extends Throwable>[]> failures, Runnable commandDispatch) Inspect the given commandMessage that failed with given lastFailure.
boolean	IntervalRetryScheduler.scheduleRetry(CommandMessage commandMessage, RuntimeException lastFailure, List<Class<? extends Throwable>[]> failures, Runnable dispatchTask)

Constructors in org.axonframework.commandhandling.gateway with parameters of type CommandMessage

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.

Uses of CommandMessage in org.axonframework.commandhandling.interceptors

Methods in org.axonframework.commandhandling.interceptors that return CommandMessage

CommandMessage<?>

BeanValidationInterceptor.handle(CommandMessage<?> command)

Methods in org.axonframework.commandhandling.interceptors with parameters of type CommandMessage

CommandMessage<?>	BeanValidationInterceptor.handle(CommandMessage<?> command)
Object	SerializationOptimizingInterceptor.handle(CommandMessage<?> commandMessage, UnitOfWork unitOfWork, InterceptorChain interceptorChain)
Object	LoggingInterceptor.handle(CommandMessage<?> command, UnitOfWork unitOfWork, InterceptorChain chain)
Object	BeanValidationInterceptor.handle(CommandMessage<?> command, UnitOfWork unitOfWork, InterceptorChain interceptorChain)

Uses of CommandMessage in org.axonframework.quickstart.handler

Methods in org.axonframework.quickstart.handler with parameters of type CommandMessage

Object	CreateToDoCommandHandler.handle(CommandMessage<CreateToDoItemCommand> commandMessage, UnitOfWork unitOfWork)
Object	MarkCompletedCommandHandler.handle(CommandMessage<MarkCompletedCommand> commandMessage, UnitOfWork unitOfWork)

Uses of CommandMessage in org.axonframework.test.utils

Methods in org.axonframework.test.utils that return types with arguments of type CommandMessage

List<CommandMessage<?>>

RecordingCommandBus.getDispatchedCommands() Returns a list with all commands that have been dispatched by this command bus.

Methods in org.axonframework.test.utils with parameters of type CommandMessage

void	RecordingCommandBus.dispatch(CommandMessage<?> command)
<R> void	RecordingCommandBus.dispatch(CommandMessage<?> command, CommandCallback<R> callback)