Package org.hive2hive.core.processes.framework.concretes

Examples of org.hive2hive.core.processes.framework.concretes.ProcessComponentListener

28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
  protected boolean executeBlocking(IProcessComponent process, String itemName) throws InterruptedException,
      InvalidProcessStateException {

    print(String.format("Executing '%s'...", itemName));

    ProcessComponentListener listener = new ProcessComponentListener();

    process.attachListener(listener);
    process.start().await();

    if (listener.hasFailed()) {
      RollbackReason reason = listener.getRollbackReason();
      print(String.format("The process has failed%s", reason != null ? ": " + reason.getHint() : "."));
    }
    return listener.hasSucceeded();
  }
View Full Code Here
115
116
117
118
119
120
121
122
123
124
125
126
127
128
    assertTrue(putLocations.isSuccess());

    IProcessComponent registerProcess = ProcessFactory.instance().createRegisterProcess(credentials,
        client);
    ProcessComponentListener listener = new ProcessComponentListener();
    registerProcess.attachListener(listener);
    registerProcess.start();

    H2HWaiter waiter = new H2HWaiter(20);
    do {
      waiter.tickASecond();
    } while (!listener.hasFailed());
  }
View Full Code Here
TOP

Related Classes of org.hive2hive.core.processes.framework.concretes.ProcessComponentListener

  • org.hive2hive.client.console.H2HConsoleMenu
  • org.hive2hive.core.processes.implementations.register.RegisterProcessTest
    • 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.