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.

            ProcessData data = new DefaultProcessData ();
            List l = new ArrayList();
            data.put("Argument", l);
            l.add ("Text:");
            process.setProcessContext(data);
            process.start();
            assertTrue (stateReached (process, "closed.completed"));
            l = (List)process.processContext().get("Result");
            assertTrue (l.size() == 2);
            assertTrue (((String)l.get(1)).equals("Hallo"));
            procDir.removeProcess(process);

View Full Code Here

      procDir = workflowService.processDirectory();
      ProcessMgr pmgr = procDefDir
    .processMgr ("jellytests", "dbTest");
      WfProcess process 
    = pmgr.createProcess(new DefaultRequester (workflowService));
      process.start();
      assertTrue (stateReached (process, "closed.completed"));
      procDir.removeProcess(process);
  } finally {
      workflowService.release (procDefDir);
      workflowService.release (procDir);

View Full Code Here

  WfProcess p = mgr1To20par.createProcess(defReq);
    }


    public void createStart11Acts () throws Exception {
  WfProcess p = mgr1To10par.createProcess(defReq);
  p.start ();
    }


}

View Full Code Here

      procDir = workflowService.processDirectory();
      ProcessMgr pmgr = procDefDir
    .processMgr ("simpleApplDirTests", "test1");
      WfProcess process 
    = pmgr.createProcess(new DefaultRequester (workflowService));
      process.start();
            WfActivity act = null;
      for (Iterator i = process.steps().iterator(); i.hasNext();) {
          act = (WfActivity)i.next ();
          if (act.name().equals("invokeTool")) {
                    break;

View Full Code Here

  }


  // Create some processes, first with null data item
  WfProcess null1 = pmgr.createProcess(req);
  WfProcess null2 = pmgr.createProcess(req);
  null2.start (); // start one to show it makes no difference


  // Now with value item
  ProcessData pd = new DefaultProcessData ();
  pd.put ("testValue", "Find this");
  WfProcess procThis1 = pmgr.createProcess(req);

View Full Code Here

      procDir = workflowService.processDirectory();
      ProcessMgr pmgr = procDefDir
    .processMgr ("jellytests", "basicTest");
      WfProcess process 
    = pmgr.createProcess(new DefaultRequester (workflowService));
      process.start();
      assertTrue (stateReached (process, "closed.completed"));
      procDir.removeProcess(process);
  } finally {
      workflowService.release (procDefDir);
      workflowService.release (procDir);

View Full Code Here

    public void runTest () throws Exception {
        WfRequester req = new DefaultRequester (workflowService());
  WfProcess process = createProcess
      ("testByAudit2", "testByAudit_emptySeq_na", req);
  assertTrue(process!=null);
  process.start ();
  assertTrue (stateReached (process, "closed"));
    }


    /**
     * Creates the process

View Full Code Here

      procDir = workflowService.processDirectory();
      ProcessMgr pmgr = procDefDir
    .processMgr ("jellytests", "insertTest");
      WfProcess process 
    = pmgr.createProcess(new DefaultRequester (workflowService));
      process.start();
      assertTrue (stateReached (process, "closed.completed"));
      procDir.removeProcess(process);
  } finally {
      workflowService.release (procDefDir);
      workflowService.release (procDir);

View Full Code Here

      procDir = workflowService.processDirectory();
      ProcessMgr pmgr = procDefDir
    .processMgr ("jellytests", "resultsTest");
      WfProcess process 
    = pmgr.createProcess(new DefaultRequester (workflowService));
      process.start();
      assertTrue (stateReached (process, "closed.completed"));
      procDir.removeProcess(process);
  } finally {
      workflowService.release (procDefDir);
      workflowService.release (procDir);

View Full Code Here

     */
    public void timeoutSynchr() throws Exception {
  ProcessMgr mgr = defDir.processMgr("SystemTest", "timeoutSynchr");
  WfProcess proc = mgr.createProcess(requester);
  String procKey = proc.key();
  proc.start();
  assertTrue(stateReached(proc, "closed.completed")); 
  ProcessData data = proc.processContext();
  String path = (String)data.get("TransitionPath");
  assertTrue(path, path.equals("PATH:act1:act2:to"));
  procDir.removeProcess(proc);

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.