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.

  procDir.removeProcess(proc);


  mgr = defDir.processMgr("SystemTest", "timeoutSynchrDefault");
  proc = mgr.createProcess(requester);
  procKey = proc.key();
  proc.start();
  assertTrue(stateReached(proc, "closed.completed")); 
  data = proc.processContext();
  path = (String)data.get("TransitionPath");
  assertTrue(path, path.equals("PATH:act1:act2:def"));
  procDir.removeProcess(proc);

View Full Code Here

     */
    public void timeoutASynchr() throws Exception {
  ProcessMgr mgr = defDir.processMgr("SystemTest", "timeoutASynchr");
  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:to1:to2:to3"));
  procDir.removeProcess(proc);

View Full Code Here

     */
    public void timeoutLoop() throws Exception {
  ProcessMgr mgr = defDir.processMgr("SystemTest", "timeoutLoop");
  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");
  Long incr = (Long)data.get("increment");
  assertTrue("I: " + incr + "; " + path,

View Full Code Here

     */
    public void timeoutSuspend() throws Exception {
  ProcessMgr mgr = defDir.processMgr("SystemTest", "suspendStartMan");
  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:start:t1:t2:end"));

View Full Code Here

  procDir.removeProcess(proc);


  mgr = defDir.processMgr("SystemTest", "suspendEndMan");
  proc = mgr.createProcess(requester);
  procKey = proc.key();
  proc.start();
  assertTrue(stateReached(proc, "closed.completed")); 
  data = proc.processContext();
  path = (String)data.get("TransitionPath");
  assertTrue(path, 
       path.equals("PATH:start:a1:t1:a2:t2:end"));

View Full Code Here

  // One test case with two variants:
  // 1. activity is suspended: (deadline is triggered after resume)
  mgr = defDir.processMgr("SystemTest", "suspendAbsolute");
  proc = mgr.createProcess(requester);
  procKey = proc.key();
  proc.start();
  Activity act = null;
  Iterator i = proc.steps().iterator();
  while (i.hasNext()) {
      act = (Activity)i.next();
      if (act.name().equals("A1")) {

View Full Code Here


  // 2. whole process is suspended: (deadline is triggered before resume 
  // but cannot be started until process is resumed)
  proc = mgr.createProcess(requester);
  procKey = proc.key();
  proc.start();
  act = null;
  i = proc.steps().iterator();
  while (i.hasNext()) {
      act = (Activity)i.next();
      if (act.name().equals("A1")) {

View Full Code Here

     */
    public void timeoutBlock() throws Exception {
  ProcessMgr mgr = defDir.processMgr("SystemTest", "timeoutBlock");
  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:start:a1:t1:a3:a2:t0:end"));

View Full Code Here

     */
    public void timeoutSubflow() throws Exception {
  ProcessMgr mgr = defDir.processMgr("SystemTest", "timeoutSubflow");
  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:start:a1:t1:a3:a2:t0:end"));

View Full Code Here

     * @exception Exception if an error occurs
     */
    public void invokeTest1() throws Exception {
  ProcessMgr pmgr = pdd.processMgr("st-testXSLT", "testXSLT1");
  WfProcess process = pmgr.createProcess(defaultRequester());
   process.start();
  assertTrue(stateReached(process, "closed.completed")); 
   Map map = (Map)process.result();
  for (Iterator it = map.keySet().iterator(); it.hasNext();) {
      String name = (String) it.next();
      if (name.equals("result")) {

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.