Package de.danet.an.workflow.omgcore

Examples of de.danet.an.workflow.omgcore.WfActivity.state()

320
321
322
323
324
325
326
327
328
329
330
            boolean found = false;
            for (Iterator i = process.steps().iterator(); i.hasNext();) {
                WfActivity act = (WfActivity)i.next ();
                if (act.name().equals("Generic")) {
                    found = true;
                    assertTrue (act.state().startsWith("open.not_running.not_started"));
                }
            }
            assertTrue (found);
            found = false;
            for (Iterator i = process.steps().iterator(); i.hasNext();) {
View Full Code Here
329
330
331
332
333
334
335
336
337
338
339
            found = false;
            for (Iterator i = process.steps().iterator(); i.hasNext();) {
                WfActivity act = (WfActivity)i.next ();
                if (act.name().equals("Normal")) {
                    found = true;
                    assertTrue (act.state().startsWith("closed.completed"));
                }
            }
            assertTrue (found);
            procDir.removeProcess(process);
        } finally {
View Full Code Here
282
283
284
285
286
287
288
289
290
291
292
    a = (WfActivity)it.next();
    if (a.name().equals ("A2" + i)) {
        break;
    }
      }
      assertTrue(a.state() != null);
      boolean exceptionCaught = false;
      assertTrue
    (a.name() + " not open.not_running.suspended: " + a.state(),
     a.state().startsWith("open.not_running.suspended"));
      a.resume();
View Full Code Here
285
286
287
288
289
290
291
292
293
294
295
    }
      }
      assertTrue(a.state() != null);
      boolean exceptionCaught = false;
      assertTrue
    (a.name() + " not open.not_running.suspended: " + a.state(),
     a.state().startsWith("open.not_running.suspended"));
      a.resume();
      Thread.sleep (1000);
      a.resume();
      Thread.sleep (1000);
View Full Code Here
286
287
288
289
290
291
292
293
294
295
296
      }
      assertTrue(a.state() != null);
      boolean exceptionCaught = false;
      assertTrue
    (a.name() + " not open.not_running.suspended: " + a.state(),
     a.state().startsWith("open.not_running.suspended"));
      a.resume();
      Thread.sleep (1000);
      a.resume();
      Thread.sleep (1000);
      assertTrue(a.name() + " not closed.completed: " + a.state(),
View Full Code Here
291
292
293
294
295
296
297
298
299
300
301
     a.state().startsWith("open.not_running.suspended"));
      a.resume();
      Thread.sleep (1000);
      a.resume();
      Thread.sleep (1000);
      assertTrue(a.name() + " not closed.completed: " + a.state(),
           a.state().startsWith("closed.completed"));
  }
  assertTrue(process.state().startsWith("closed.completed"));
    }
View Full Code Here
292
293
294
295
296
297
298
299
300
301
302
      a.resume();
      Thread.sleep (1000);
      a.resume();
      Thread.sleep (1000);
      assertTrue(a.name() + " not closed.completed: " + a.state(),
           a.state().startsWith("closed.completed"));
  }
  assertTrue(process.state().startsWith("closed.completed"));
    }

    /**
 
View Full Code Here
335
336
337
338
339
340
341
342
343
344
345
  assertTrue(a41.state().startsWith("open.not_running.suspended"));
  a41.resume();
  Thread.sleep (1000);
  assertTrue(a42.state().startsWith("open.not_running.suspended"));
  assertTrue(a43.state().startsWith("open.not_running.not_started"));
  assertTrue(a44.state().startsWith("open.not_running.not_started"));
  // start A42
  a42.resume();
  Thread.sleep (1000);
  assertTrue(a43.state().startsWith("open.not_running.not_started"));
  assertTrue(a44.state().startsWith("open.not_running.suspended"));
View Full Code Here
340
341
342
343
344
345
346
347
348
349
350
  assertTrue(a44.state().startsWith("open.not_running.not_started"));
  // start A42
  a42.resume();
  Thread.sleep (1000);
  assertTrue(a43.state().startsWith("open.not_running.not_started"));
  assertTrue(a44.state().startsWith("open.not_running.suspended"));
  // start A44
  a44.resume();
  Thread.sleep (1000);
  // process terminated
  assertTrue(process.state().startsWith("closed.completed"));
View Full Code Here
439
440
441
442
443
444
445
446
447
448
449
                 String state)
  throws Exception {
  Iterator it = proc.steps().iterator();
  while (it.hasNext()) {
      WfActivity a = (WfActivity)it.next();
      if (!a.state().startsWith(state)) {
    return false;
      }
  }
  return true;
    }
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.