components/src/test/java/eu/internetofus/common/components/Containers.java
/**
   * Start the task manager container if it is not started yet.
   *
   * @return this containers instance.
   */
Start the task manager container if it is not started yet.
@return this containers instance.
Start the task manager container if it is not started yet . @return this containers instance .
@SuppressWarnings("resource")
  public Containers startTaskManagerContainer() {
    if (this.taskManagerContainer == null) {
      Logger.trace("Starting Task Manager");
      this.taskManagerContainer = new WeNetComponentContainer<>(WENET_TASK_MANAGER_DOCKER_NAME, this.taskManagerApiPort)
          .with(this).withEnv("WENET_PROFILE_MANAGER_API", this.getProfileManagerApi())
          .withEnv("WENET_INTERACTION_PROTOCOL_ENGINE_API", this.getInteractionProtocolEngineApi())
          .withEnv("WENET_SERVICE_API", this.service.getApiUrl())
          .withEnv("COMP_AUTH_KEY", DEFAULT_WENET_COMPONENT_APIKEY).waitingFor(Wait.forListeningPort());
      this.taskManagerContainer.start();
      Logger.trace("Started Task Manager");
    }
    return this;
  }
@ SuppressWarnings ( "resource" ) public Containers startTaskManagerContainer ( ) { if ( this . taskManagerContainer == null ) { Logger . trace ( "Starting Task Manager" ) ; this . taskManagerContainer = new WeNetComponentContainer < > ( WENET_TASK_MANAGER_DOCKER_NAME , this . taskManagerApiPort ) . with ( this ) . withEnv ( "WENET_PROFILE_MANAGER_API" , this . getProfileManagerApi ( ) ) . withEnv ( "WENET_INTERACTION_PROTOCOL_ENGINE_API" , this . getInteractionProtocolEngineApi ( ) ) . withEnv ( "WENET_SERVICE_API" , this . service . getApiUrl ( ) ) . withEnv ( "COMP_AUTH_KEY" , DEFAULT_WENET_COMPONENT_APIKEY ) . waitingFor ( Wait . forListeningPort ( ) ) ; this . taskManagerContainer . start ( ) ; Logger . trace ( "Started Task Manager" ) ; } return this ; }
Start the task manager container if it is not started yet.
Start the task manager container if it is not started yet .