org.axonframework.commandhandling.distributed

Class CommandCallbackRepository<A>

java.lang.Object

org.axonframework.commandhandling.distributed.CommandCallbackRepository<A>

Type Parameters:

A - The type of the endpoint identifier.

public class CommandCallbackRepository<A>
extends Object

This class retains a list of callbacks for CommandCallbackConnectors to use.

Constructor Summary

Constructors

Constructor and Description
CommandCallbackRepository()

Method Summary

Modifier and Type	Method and Description
protected Map<String,CommandCallbackWrapper>	callbacks() Returns the callbacks mapped by callback identifier.
void	cancelCallbacks(A channelId) Deprecated. use cancelCallbacksForChannel(Object) instead
Collection<CommandCallbackWrapper>	cancelCallbacksForChannel(A channelId) Removes all callbacks for a given channel.
<E,C,R> CommandCallbackWrapper<E,C,R>	fetchAndRemove(String callbackId) Fetches and removes a callback.
<E,C,R> void	store(String callbackId, CommandCallbackWrapper<E,C,R> commandCallbackWrapper) Stores a callback

Methods inherited from class java.lang.Object

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

Constructor Detail

CommandCallbackRepository

public CommandCallbackRepository()

Method Detail

cancelCallbacks

public void cancelCallbacks(A channelId)

Deprecated. use cancelCallbacksForChannel(Object) instead

Removes all callbacks for a given channel. Registered callbacks will receive a failure response containing a CommandBusConnectorCommunicationException.

Parameters:

channelId - the channel identifier

cancelCallbacksForChannel

public Collection<CommandCallbackWrapper> cancelCallbacksForChannel(A channelId)

Removes all callbacks for a given channel. Registered callbacks will receive a failure response containing a CommandBusConnectorCommunicationException.

Parameters:

channelId - the channel identifier

Returns:

the collection of removed callbacks

fetchAndRemove

public <E,C,R> CommandCallbackWrapper<E,C,R> fetchAndRemove(String callbackId)

Fetches and removes a callback. The callback will not be used a second time, so removal should be fine

Type Parameters:

E - The type of the remote endpoint identifier

C - The type of the command

R - The type of the result

Parameters:

callbackId - The Callback Id to fetch the callback for

Returns:

The stored CommandCallbackWrapper or null if not found

store

public <E,C,R> void store(String callbackId,
                          CommandCallbackWrapper<E,C,R> commandCallbackWrapper)

Stores a callback

Type Parameters:

E - The type of the remote endpoint identifier

C - The type of the command

R - The type of the result

Parameters:

callbackId - The id to store the callback with

commandCallbackWrapper - The CommandCallbackWrapper to store

callbacks

protected Map<String,CommandCallbackWrapper> callbacks()

Returns the callbacks mapped by callback identifier.

Returns:

the command callbacks by id