Examples of de.danet.an.workflow.omgcore.WfProcess.start()

Class de.danet.an.workflow.omgcore.WfProcess

Examples of de.danet.an.workflow.omgcore.WfProcess.start()

de.danet.an.workflow.omgcore.WfProcess.start()
Initiate enactment of a WfProcess. @throws RemoteException if a system-level error occurs. @throws CannotStartException when the process cannot be started (e.g.,because it is not properly initialized). @throws AlreadyRunningException when the process has already been started.

      ProcessMgr pmgr = procDefDir.processMgr
    ("chabacc", "chabacc_test_close_notification");
      WfProcess process 
    = pmgr.createProcess(new DefaultRequester (workflowService));
      chan = workflowService.getChannel(process, "test_channel");
      process.start();
      Map pd = chan.receiveMessage();
      assertTrue (pd == null);
      assertTrue (stateReached (process, "closed.completed"));
      procDir.removeProcess(process);
  } finally {

View Full Code Here

     */
    public void createAndStartProcess1() throws Exception {
  WfRequester cont = new DefaultRequester(workflowService());
  WfProcess process = createProcess("ut-process", "jut1", cont);
  assertTrue(process.state().startsWith("open.not_running.not_started"));
  process.start();
  assertTrue(process.state().startsWith("open.running"));
  // get the activities 
  Collection c = process.steps();
  Iterator it = c.iterator();
  while (it.hasNext()) {

View Full Code Here

     */
    public void createAndStartProcess2() throws Exception {
  WfRequester cont = new DefaultRequester(workflowService());
  WfProcess process = createProcess("ut-process", "jut2", cont);
  assertTrue(process.state().startsWith("open.not_running.not_started"));
  process.start();
  assertTrue(process.state().startsWith("open.running"));
  // get the activities 
  Collection c = process.steps();
  Iterator it = c.iterator();
  while (it.hasNext()) {

View Full Code Here

     */
    public void createAndStartProcess3() throws Exception {
  WfRequester cont = new DefaultRequester(workflowService());
  WfProcess process = createProcess("ut-process", "jut3", cont);
  assertTrue(process.state().startsWith("open.not_running.not_started"));
  process.start();
  Thread.sleep(2500);
  assertTrue(process + " should be completed, is " + process.state(),
       process.state().startsWith("closed.completed"));
  // get the activities 
  Collection c = process.steps();

View Full Code Here

     */
    public void createProcess2() throws Exception {
  WfRequester cont = new DefaultRequester(workflowService());
   WfProcess process = createProcess("ut-process", "jut2", cont);
  assertTrue(process.state().startsWith("open.not_running.not_started"));
    process.start();
  Thread.sleep (1000);
  assertTrue(process.state().startsWith("open.running"));
  int i = 9;
  int resCnt = 0;
  while (i-- > 0) {

View Full Code Here

     */
    public void createProcess3() throws Exception {
  WfRequester cont = new DefaultRequester(workflowService());
  WfProcess process = createProcess("ut-process", "jut3", cont);
  assertTrue(process.state().startsWith("open.not_running.not_started"));
    process.start();
  Thread.sleep (5000);
  assertTrue("Process state should be closed.completed.normal, is " 
       + process.state(),
       process.state().startsWith("closed.completed.normal"));
  assertTrue("Process workflow state should be closed, is "

View Full Code Here

     */
    public void createAndStartProcess1() throws Exception {
  WfRequester cont = new DefaultRequester(workflowService());
  WfProcess process = createProcess("ut-process", "jut1", cont);
  assertTrue(process.state().startsWith("open.not_running.not_started"));
  process.start();
  assertTrue(process.state().startsWith("open.running"));
  // get the activities 
  Collection c = process.steps();
  Iterator it = c.iterator();
  while (it.hasNext()) {

View Full Code Here

     */
    public void createAndStartProcess2() throws Exception {
  WfRequester cont = new DefaultRequester(workflowService());
  WfProcess process = createProcess("ut-process", "jut2", cont);
  assertTrue(process.state().startsWith("open.not_running.not_started"));
  process.start();
  assertTrue(process.state().startsWith("open.running"));
  // get the activities 
  Collection c = process.steps();
  Iterator it = c.iterator();
  while (it.hasNext()) {

View Full Code Here

     */
    public void createAndStartProcess3() throws Exception {
  WfRequester cont = new DefaultRequester(workflowService());
  WfProcess process = createProcess("ut-process", "jut3", cont);
  assertTrue(process.state().startsWith("open.not_running.not_started"));
  process.start();
  Thread.sleep(2500);
  assertTrue(process + " should be completed, is " + process.state(),
       process.state().startsWith("closed.completed"));
  // get the activities 
  Collection c = process.steps();

View Full Code Here

    //Suspend Process then resume it
    private void suspendresumeProcess() throws Exception {
  WfRequester req = new DefaultRequester(workflowService);
  WfProcess process = createProcess("ut-process", "jut2", req);
  assertTrue(process.state().equals("open.not_running.not_started"));
  process.start();
  assertTrue(process.state().equals("open.running"));
  process.suspend();
  assertTrue(process.state().equals("open.not_running.suspended"));
  process.resume();
  assertTrue(process.state().equals("open.running"));

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

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.