public TargetModuleID distributeModuleStream()

in src/main/java/org/apache/openejb/cts/deploy/DeployTestUtil.java [306:330]

• 21 lines of code
• 4 McCabe index (conditional complexity)

  public TargetModuleID distributeModuleStream(Target[] targets,
      ModuleType moduleType, InputStream moduleArchive,
      InputStream deploymentPlan, boolean oneDotFiveApi) throws Exception {
    String apiType = (oneDotFiveApi == true) ? "1.5 API" : "deprecated API";
    TestUtil.logMsg("Calling distribute(): Using " + apiType);
    DeploymentManager dm = getDeploymentManager();
    ProgressHandler progressHandler = new ProgressHandler();
    ProgressObject progress = dm.distribute(targets, moduleArchive, deploymentPlan);
    progress.addProgressListener(progressHandler);
    progressHandler.start();
    // Wait for the progress handler to complete its job
    progressHandler.join();
    StateType completionState = progressHandler.getCompletionState();
    if (completionState.getValue() != StateType.COMPLETED.getValue()) {
      // The state must be either FAILED, or RELEASED
      return null;
    }
    TargetModuleID[] resultModuleIDs = progress.getResultTargetModuleIDs();
    if (resultModuleIDs.length < 1) {
      // There should be atleast one target module id if progress is
      // successfully complete
      return null;
    }
    return resultModuleIDs[0];
  }