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.

  // create the process
  WfProcess process 
      = createProcess("ut-process", "jut_tool_invocation", req);
  assertTrue(process.state().equals("open.not_running.not_started"));
  // start the process
  process.start();
  Thread.sleep (1000);
  assertTrue(process.state().startsWith("open.running"));
  WfActivity act = actByName(process, "Account Antrag erstellen");
  assertTrue(invoke(act));
  act = actByName(process, "Account Antrag bearbeiten");

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

    sleepAct = (WfActivity)i.next ();
    if (sleepAct.name().equals("Wait")) {
        break;
    }
      }
      process.start();
      assertTrue (stateReached (sleepAct, "open.running"));
      Map pd = chan.receiveMessage();
      assertTrue ("Hello world!".equals(pd.get("message")));
      assertTrue (stateReached (process, "closed.completed"));
      procDir.removeProcess(process);

View Full Code Here

    if (recAct.name().equals("Receive")) {
        break;
    }
      }
      assertTrue (recAct != null);
      process.start();
      assertTrue (stateReached (recAct, "open.running"));
      Thread.sleep (500);
      Map pd = new HashMap ();
      pd.put ("message", "Hello world!");
      chan.sendMessage(pd);

View Full Code Here

      chan = workflowService.getChannel(process, "test_channel");
      Map pd = new HashMap ();
      pd.put ("message", "Hello world!");
      chan.sendMessage(pd);
      Thread.sleep (500);
      process.start();
      assertTrue (stateReached (process, "closed.completed"));
      pd = process.processContext();
      assertTrue ("Hello world!".equals(pd.get("lastMessage")));
      procDir.removeProcess(process);
  } finally {

View Full Code Here

            b.pack();
      Map pd = new HashMap ();
      pd.put ("message", b);
      chan.sendMessage(pd);
      Thread.sleep (500);
      process.start();
      assertTrue (stateReached (process, "closed.completed"));
            pd = process.processContext();
            Object o = pd.get("lastXMLMessage");
            assertTrue (o != null);
            assertTrue (o instanceof SAXContentBuffer);

View Full Code Here

      procDir = workflowService.processDirectory();
      ProcessMgr pmgr = procDefDir.processMgr
    ("chabacc", "chabacc_test_send_self");
      WfProcess process 
    = pmgr.createProcess(new DefaultRequester (workflowService));
      process.start();
      assertTrue (stateReached (process, "closed.completed"));
      ProcessData pd = process.processContext();
      assertTrue ("Hello world!".equals(pd.get("lastMessage")));
      procDir.removeProcess(process);
  } finally {

View Full Code Here

    = pmgr.createProcess(new DefaultRequester (workflowService));
      chan = workflowService.getChannel(process, "test_channel");
      Map pd = new HashMap ();
      pd.put ("message", "Do you echo?");
      chan.sendMessage(pd);
      process.start();
      pd = chan.receiveMessage();
      assertTrue ("Got: " + pd.get("message"), 
      "Do you echo?".equals(pd.get("message")));
      assertTrue (stateReached (process, "closed.completed"));
      procDir.removeProcess(process);

View Full Code Here

    = pmgr.createProcess(new DefaultRequester (workflowService));
      chan = workflowService.getChannel(process, "test_channel");
      Map pd = new HashMap ();
      pd.put ("message", "Do you echo?");
      chan.sendMessage(pd);
      process.start();
      pd = chan.receiveMessage();
      assertTrue ("Got: " + pd.get("message"), 
      "Do you echo?".equals(pd.get("message")));
      assertTrue (stateReached (process, "closed.completed"));
      pd = process.processContext();

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.