Package de.danet.an.workflow.api

Examples of de.danet.an.workflow.api.Process.start()

409
410
411
412
413
414
415
416
417
418
419
  ProcessDefinitionDirectory pdd = null;
  try {
      WfRequester cont = new DefaultRequester(workflowService());
      Process process = (Process)createProcess("ut-process", "jut1", cont);
      assertTrue(process.state().startsWith("open.not_running.not_started"));
      process.start();
      assertTrue(process.state().startsWith("open.running"));
      // remove its process definition
      pdd = workflowService().processDefinitionDirectory ();
      ProcessDefinition pd
    = pdd.lookupProcessDefinition("ut-process", "jut1");
View Full Code Here
303
304
305
306
307
308
309
310
311
312
313
  ProcessDefinitionDirectory pdd = null;
  try {
      WfRequester cont = new DefaultRequester(workflowService());
      Process process = (Process)createProcess("ut-process", "jut1", cont);
      assertTrue(process.state().startsWith("open.not_running.not_started"));
      process.start();
      assertTrue(process.state().startsWith("open.running"));
      // remove its process definition
      pdd = workflowService().processDefinitionDirectory ();
      ProcessDefinition pd
    = pdd.lookupProcessDefinition("ut-process", "jut1");
View Full Code Here
171
172
173
174
175
176
177
178
179
180
181
    public void createProcessAndRemoveProcessDef() throws Exception { 
  ProcessDefinitionDirectory pdd = null;
  try {
      WfRequester cont = new DefaultRequester(workflowService());
      Process process = (Process)createProcess("N1", "N2", cont);
      process.start();
      Thread.sleep(5000);

      // get processdata
      ProcessData data = process.processContext();
      Object value = data.get("result");
View Full Code Here
311
312
313
314
315
316
317
318
319
320
321
            Process p = (Process)pmgr.createProcess
                (new DefaultRequester(wsc.getWorkflowService()));
            if (isStartInDebugMode()) {
                p.setDebugEnabled (true);
            }
            p.start ();
            setStartInDebugMode(false);
        } catch (InvalidStateException e) {
            // shouldn't happen
            logger.error (e.getMessage (), e);
        } catch (RequesterRequiredException e) {
View Full Code Here
461
462
463
464
465
466
467
468
469
470
471
  WfRequester req = new DefaultRequester(workflowService);
  // create the process
  Process process = (Process)(createProcess("ut-process", "jut1", req));
  assertTrue(process.state().equals("open.not_running.not_started"));
  // start the process
  process.start();
  assertTrue(process.state().startsWith("open.running"));
  Thread.sleep (1000);
  // start the first two activities and stop it.
  Collection c = process.steps();
  for (int i = 1; i <= 2; i++) {
View Full Code Here
552
553
554
555
556
557
558
559
560
561
562
  // create the process
  Process process = (Process)(createProcess("ut-process", "jut5", req));
  String processKey = process.key();
  assertTrue(process.state().equals("open.not_running.not_started"));
  // start the process
  process.start();
  assertTrue(process.state().startsWith("open.running"));
  Thread.sleep (1000);
  process.suspend();
  process.abort();
  Thread.sleep (2000);
View Full Code Here
173
174
175
176
177
178
179
180
181
182
183
  try {
      pd = workflowService().processDirectory ();
      WfRequester cont = new DefaultRequester(workflowService());
      Process process = (Process)createProcess
    ("actParamTests", "jelly-test1", cont);
      process.start();
      assertTrue (stateReached (process, "closed.completed"));
      SAXEventBuffer res = (SAXEventBuffer)
    process.processContext().get ("result");
      SAXHandler sh = new SAXHandler ();
      res.emit (sh);
View Full Code Here
205
206
207
208
209
210
211
212
213
214
215
        try {
            pd = workflowService().processDirectory ();
            WfRequester cont = new DefaultRequester(workflowService());
            Process process = (Process)createProcess
                ("actParamTests", "testE4xActParam", cont);
            process.start();
            assertTrue (stateReached (process, "closed.completed"));
            SAXContentBuffer res = (SAXContentBuffer)
                process.processContext().get ("result");
            Node resRoot = res.toW3cDom();
            Node fc = resRoot.getFirstChild();
View Full Code Here
163
164
165
166
167
168
169
170
171
172
173
  try {
      pd = workflowService().processDirectory ();
      WfRequester cont = new DefaultRequester(workflowService());
      Process process = (Process)createProcess
    ("jelly-test", "jelly-test1", cont);
      process.start();
      assertTrue (stateReached (process, "closed.completed"));
      SAXEventBuffer res = (SAXEventBuffer)
    process.processContext().get ("result");
      SAXHandler sh = new SAXHandler ();
      res.emit (sh);
View Full Code Here
167
168
169
170
171
172
173
174
175
176
177
    public void createProcessAndRemoveProcessDef() throws Exception { 
  ProcessDefinitionDirectory pdd = null;
  try {
      WfRequester cont = new DefaultRequester(workflowService());
      Process process = (Process)createProcess("N1", "N2", cont);
      process.start();
      Thread.sleep(5000);

      // get processdata
      ProcessData data = process.processContext();
      Object value = data.get("result");
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.