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.