A
- The type of the endpoint identifier.public class CommandCallbackRepository<A> extends Object
Constructor and Description |
---|
CommandCallbackRepository() |
Modifier and Type | Method and Description |
---|---|
protected Map<String,CommandCallbackWrapper> |
callbacks()
Returns the callbacks mapped by callback identifier.
|
void |
cancelCallbacks(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
|
public void cancelCallbacks(A channelId)
CommandBusConnectorCommunicationException
.channelId
- the channel identifierpublic <E,C,R> CommandCallbackWrapper<E,C,R> fetchAndRemove(String callbackId)
E
- The type of the remote endpoint identifierC
- The type of the commandR
- The type of the resultcallbackId
- The Callback Id to fetch the callback forpublic <E,C,R> void store(String callbackId, CommandCallbackWrapper<E,C,R> commandCallbackWrapper)
E
- The type of the remote endpoint identifierC
- The type of the commandR
- The type of the resultcallbackId
- The id to store the callback withcommandCallbackWrapper
- The CommandCallbackWrapper to storeprotected Map<String,CommandCallbackWrapper> callbacks()
Copyright © 2010–2019. All rights reserved.