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,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
void	fail(Throwable e) Invokes CommandCallback.onFailure(CommandMessage, Throwable) with given exception on the wrapped callback.
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	onFailure(CommandMessage<? extends C> message, Throwable cause) Invoked when command handling execution resulted in an error.
void	onSuccess(CommandMessage<? extends C> message, R result) Invoked when command handling execution was successful.
void	success(R result) Invokes CommandCallback.onSuccess(CommandMessage, Object) 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,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

fail

public void fail(Throwable e)

Invokes CommandCallback.onFailure(CommandMessage, Throwable) with given exception on the wrapped callback.

Parameters:

e - cause for the failure

success

public void success(R result)

Invokes CommandCallback.onSuccess(CommandMessage, Object) with given result on the wrapped callback.

Parameters:

result - the result of the command

onSuccess

public void onSuccess(CommandMessage<? extends C> message,
                      R result)

Description copied from interface: CommandCallback

Invoked when command handling execution was successful.

Specified by:

onSuccess in interface CommandCallback<C,R>

Parameters:

message - The message that was dispatched

result - The result of the command handling execution, if any.

onFailure

public void onFailure(CommandMessage<? extends C> message,
                      Throwable cause)

Description copied from interface: CommandCallback

Invoked when command handling execution resulted in an error.

Specified by:

onFailure in interface CommandCallback<C,R>

Parameters:

message - The message that was dispatched

cause - The exception raised during command handling