Package org.springframework.xd.dirt.core.DeploymentUnitStatus

Examples of org.springframework.xd.dirt.core.DeploymentUnitStatus.State

283
284
285
286
287
288
289
290
    }
  }

  private boolean waitForUndeploy(StreamDefinition definition) {
    streamDeployer.undeploy(definition.getName());
    State state = streamResourceStateVerifier.waitForUndeploy(definition.getName());
    return state.equals(State.undeployed);
  }
View Full Code Here
293
294
295
296
297
298
299
300
301
302
303
304
    return waitForDeploy(definition, EMPTY_PROPERTIES);
  }

  private boolean waitForDeploy(StreamDefinition definition, Map<String, String> properties) {
    streamDeployer.deploy(definition.getName(), properties);
    State state = streamStateVerifier().waitForDeploy(definition.getName());
    if (state.equals(State.deployed)) {
      return true;
    }
    return false;

  }
View Full Code Here
303
304
305
306
307
308
309
310
311
312
313
  }

  private boolean waitForDeploy(StreamDefinition definition, Map<String, String> properties, boolean allowIncomplete) {
    streamDeployer.deploy(definition.getName(), properties);
    State state = streamResourceStateVerifier.waitForDeploy(definition.getName(), allowIncomplete);
    if (allowIncomplete) {
      return state.equals(State.deployed) || state.equals(State.incomplete);
    }
    return state.equals(State.deployed);
  }
View Full Code Here
TOP

Related Classes of org.springframework.xd.dirt.core.DeploymentUnitStatus.State

  • org.springframework.xd.dirt.test.SingleNodeIntegrationTestSupport
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.