org.axonframework.commandhandling.gateway

Class AbstractCommandGateway

java.lang.Object

org.axonframework.commandhandling.gateway.AbstractCommandGateway

Direct Known Subclasses:

DefaultCommandGateway

public abstract class AbstractCommandGateway
extends Object

Abstract implementation of a CommandGateway, which handles the dispatch interceptors and retrying on failure. The actual dispatching of commands is left to the subclasses.

Since:

2.2

Author:

Allard Buijze

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractCommandGateway(CommandBus commandBus, RetryScheduler retryScheduler, List<CommandDispatchInterceptor> commandDispatchInterceptors) Initialize the AbstractCommandGateway with given commandBus, retryScheduler and commandDispatchInterceptors.

Method Summary

Methods

Modifier and Type	Method and Description
protected CommandMessage	processInterceptors(CommandMessage commandMessage) Invokes all the dispatch interceptors and returns the CommandMessage instance that should be dispatched.
protected <R> void	send(Object command, CommandCallback<R> callback) Sends the given command, and invokes the callback when the command is processed.
protected void	sendAndForget(Object command) Dispatches a command without callback.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AbstractCommandGateway

protected AbstractCommandGateway(CommandBus commandBus,
                      RetryScheduler retryScheduler,
                      List<CommandDispatchInterceptor> commandDispatchInterceptors)

Initialize the AbstractCommandGateway with given commandBus, retryScheduler and commandDispatchInterceptors.

Parameters:

commandBus - The command bus on which to dispatch events

retryScheduler - The scheduler capable of performing retries of failed commands. May be null when to prevent retries.

commandDispatchInterceptors - The interceptors to invoke when dispatching a command

Method Detail

send

protected <R> void send(Object command,
            CommandCallback<R> callback)

Sends the given command, and invokes the callback when the command is processed.

Type Parameters:

R - The type of response expected from the command

Parameters:

command - The command to dispatch

callback - The callback to notify with the processing result

sendAndForget

protected void sendAndForget(Object command)

Dispatches a command without callback. When dispatching fails, since there is no callback, the command will not be retried.

Parameters:

command - The command to dispatch

processInterceptors

protected CommandMessage processInterceptors(CommandMessage commandMessage)

Invokes all the dispatch interceptors and returns the CommandMessage instance that should be dispatched.

Parameters:

commandMessage - The incoming command message

Returns:

The command message to dispatch