code: 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();
    }
docs: Starts RTS process.
  @throws IOException