public interface IStrategyManager<DESCRIPTOR extends IStrategyDescriptor,LISTENER extends StrategyListener<DESCRIPTOR>>
| Modifier and Type | Method and Description |
|---|---|
void |
addStrategyListener(LISTENER strategyListener)
Sets the listener for remote strategies.
|
Future<IStrategyResponse<Set<DESCRIPTOR>>> |
getStartedStrategies()
Returns a set of started strategies.
|
void |
removeStrategyListener(LISTENER strategyListener)
Removes the listener if it exists
|
Future<IStrategyResponse<Void>> |
stopStrategy(UUID processId)
Stops the remote strategy of the specified id.
|
void addStrategyListener(LISTENER strategyListener)
//add a listener to a remote strategy manager, for local strategy manager use LocalStrategyListener
strategyManager.addStrategyListener(new RemoteStrategyListener() {
@Override
public void onStrategyRun(IRemoteStrategyDescriptor descriptor) {
System.out.println("strategy launched: " + descriptor);
};
@Override
public void onStrategyStop(IRemoteStrategyDescriptor descriptor) {
System.out.println("strategy stopped: " + descriptor);
};
});
strategyListener - listenervoid removeStrategyListener(LISTENER strategyListener)
strategyListener - the removable listenerFuture<IStrategyResponse<Void>> stopStrategy(UUID processId)
// stop without processing the server response
strategyManager.stopStrategy(myStrategyId);
// stop with processing the server response
IStrategyResponse<Void> stopResponse = strategyManager.stopStrategy(myStrategyId).get();
if (stopResponse.isError()) {
System.err.println("Strategy failed to stop: " + startResponse.getErrorMessage());
} else {
myStrategyId = startResponse.getResult();
System.out.println("Strategy successfully stopped: " + myStrategyId);
}
processId - id of the strategyFuture object for obtaining the server responseFuture<IStrategyResponse<Set<DESCRIPTOR>>> getStartedStrategies()
//Retrieve remote strategies from a remote strategy manager, to retrieve local strategies use ILocalStrategyManager
IStrategyResponse<Set<IRemoteStrategyDescriptor>> listResponse = strategyManager.getStartedStrategies().get();
if (listResponse.isError()) {
System.err.println("Failed to retrieve remote strategy list");
} else {
Set<IRemoteStrategyDescriptor> strategyDescriptors = listResponse.getResult();
System.out.println("Remotely started " + strategyDescriptors.size() + " strategies: ");
for (IStrategyDescriptor strategyDescriptor : strategyDescriptors) {
System.out.println(strategyDescriptor.toString());
}
}
Future object for obtaining the server responseCopyright © 2016. All rights reserved.