org.axonframework.commandhandling.distributed

Class CommandCallbackWrapper<A,C,R>

java.lang.Object

org.axonframework.commandhandling.distributed.CommandCallbackWrapper<A,C,R>

Type Parameters:

A - The type of the session identifier

C - The type of the command

R - The type of the expected result

All Implemented Interfaces:

CommandCallback<C,R>

public class CommandCallbackWrapper<A,C,R>
extends Object
implements CommandCallback<C,R>

Wrapper for a Command callback. This is used in a CommandCallbackRepository

Author:

Koen Lavooij

Constructor Summary

Constructors

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.

Method Summary

Modifier and Type	Method and Description
A	getChannelIdentifier() Returns the identifier of the channel over which the command message was sent.
CommandMessage<C>	getMessage() Returns the command message that was sent.
void	onResult(CommandMessage<? extends C> message, CommandResultMessage<? extends R> commandResultMessage) Invoked when command handling execution is completed.
void	reportResult(CommandResultMessage<R> result) Invokes CommandCallback.onResult(CommandMessage, CommandResultMessage) with given result on the wrapped callback.

Methods inherited from class java.lang.Object

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

Constructor Detail

CommandCallbackWrapper

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

Parameters:

channelId - used to identify the channel used to send the message

message - the command message that was sent

callback - the command callback to notify when the command result is received

Method Detail

getMessage

public CommandMessage<C> getMessage()

Returns the command message that was sent.

Returns:

the sent message

getChannelIdentifier

public A getChannelIdentifier()

Returns the identifier of the channel over which the command message was sent.

Returns:

the identifier of the channel over which the command message was sent

reportResult

public void reportResult(CommandResultMessage<R> result)

Invokes CommandCallback.onResult(CommandMessage, CommandResultMessage) with given result on the wrapped callback.

Parameters:

result - the result of the command

onResult

public void onResult(CommandMessage<? extends C> message,
                     CommandResultMessage<? extends R> commandResultMessage)

Description copied from interface: CommandCallback

Invoked when command handling execution is completed.

Specified by:

onResult in interface CommandCallback<C,R>

Parameters:

message - the CommandMessage that was dispatched

commandResultMessage - the CommandResultMessage of the command handling execution