public void startRTS() throws IOException {
    List<HubDataSource> dataSources = hubDataStore.getHubDataSources();
    List<String> com = Lists.newArrayList();
    com.add(getHostPort(hubDataStore.getHubAddress()));
    com.add(hubDataStore.getInstanceName());
    for (HubDataSource source : dataSources) {
      com.add(source.getName());
    }
    ExternalProgramExecutor executorService = new ExternalProgramExecutor(
      "RTS", new File(binLocation, "rts"), com.toArray(new String[com.size()]));
    rtsExecutor.add(executorService);
    LOG.info("Starting RTS : {}", executorService);
    executorService.startAndWait();
  }
public void startRTS ( ) throws IOException { List < HubDataSource > dataSources = hubDataStore . getHubDataSources ( ) ; List < String > com = Lists . newArrayList ( ) ; com . add ( getHostPort ( hubDataStore . getHubAddress ( ) ) ) ; com . add ( hubDataStore . getInstanceName ( ) ) ; for ( HubDataSource source : dataSources ) { com . add ( source . getName ( ) ) ; } ExternalProgramExecutor executorService = new ExternalProgramExecutor ( "RTS" , new File ( binLocation , "rts" ) , com . toArray ( new String [ com . size ( ) ] ) ) ; rtsExecutor . add ( executorService ) ; LOG . info ( "Starting RTS : {}" , executorService ) ; executorService . startAndWait ( ) ; }
Starts RTS process.
@throws IOException