[jbpm-commits] JBoss JBPM SVN: r2154 - jbpm3/trunk/modules/core/src/test/java/org/jbpm/job/executor.
Author: thomas.diesler(a)jboss.com
Date: 2008-09-09 10:49:37 -0400 (Tue, 09 Sep 2008)
New Revision: 2154
Modified:
jbpm3/trunk/modules/core/src/test/java/org/jbpm/job/executor/MultiJobExecutorDbTest.java
Log:
Comment System.out.println in core tests
Modified:
jbpm3/trunk/modules/core/src/test/java/org/jbpm/job/executor/MultiJobExecutorDbTest.java
===================================================================
---
jbpm3/trunk/modules/core/src/test/java/org/jbpm/job/executor/MultiJobExecutorDbTest.java 2008-09-09
14:41:32 UTC (rev 2153)
+++
jbpm3/trunk/modules/core/src/test/java/org/jbpm/job/executor/MultiJobExecutorDbTest.java 2008-09-09
14:49:37 UTC (rev 2154)
@@ -49,36 +49,42 @@
+ "<end-state name='end-state1' />"
+ "</process-definition>";
- protected void setUp() throws SQLException {
+ protected void setUp() throws SQLException
+ {
jbpmConfiguration.createSchema();
// deploy process definition
JbpmContext jbpmContext = jbpmConfiguration.createJbpmContext();
- try {
+ try
+ {
jbpmContext.deployProcessDefinition(ProcessDefinition.parseXmlString(PROCESS_DEFINITION));
}
- finally {
+ finally
+ {
jbpmContext.close();
}
}
- public void testMultipleJobExecutors() {
+ public void testMultipleJobExecutors()
+ {
// start job executors
- for (int i = 0; i < executors.length; i++) {
- executors[i] = (JobExecutor)
JbpmConfiguration.Configs.getObjectFactory().createObject(
- "jbpm.job.executor");
+ for (int i = 0; i < executors.length; i++)
+ {
+ executors[i] =
(JobExecutor)JbpmConfiguration.Configs.getObjectFactory().createObject("jbpm.job.executor");
executors[i].setName("JbpmJobExecutor/" + (i + 1));
executors[i].start();
}
// kick off process instance
JbpmContext jbpmContext = jbpmConfiguration.createJbpmContext();
- try {
+ try
+ {
ProcessInstance processInstance =
jbpmContext.newProcessInstanceForUpdate(PROCESS_NAME);
processInstance.getContextInstance().setVariable("eventCallback", new
EventCallback());
processInstance.signal();
}
- finally {
+ finally
+ {
jbpmContext.close();
}
@@ -86,11 +92,14 @@
EventCallback.waitForEvent(Event.EVENTTYPE_PROCESS_END);
// stop job executors
- for (int i = executors.length - 1; i >= 0; i--) {
- try {
+ for (int i = executors.length - 1; i >= 0; i--)
+ {
+ try
+ {
executors[i].stopAndJoin();
}
- catch (InterruptedException e) {
+ catch (InterruptedException e)
+ {
// continue to next executor
}
}
@@ -98,37 +107,43 @@
assertEquals(1, SimpleAction2.getExecutionCount());
}
- protected void tearDown() {
+ protected void tearDown()
+ {
jbpmConfiguration.dropSchema();
}
- public static class SimpleAction implements ActionHandler {
+ public static class SimpleAction implements ActionHandler
+ {
private static final long serialVersionUID = 1L;
- public void execute(ExecutionContext exeContext) throws Exception {
- // System.out.println("Action 1");
+ public void execute(ExecutionContext exeContext) throws Exception
+ {
exeContext.leaveNode();
}
}
- public static class SimpleAction2 implements ActionHandler {
+ public static class SimpleAction2 implements ActionHandler
+ {
private static int executionCount = 0;
private static final long serialVersionUID = 1L;
- public void execute(ExecutionContext exeContext) throws Exception {
- // System.out.println("Action 2: " + incrementCount());
+ public void execute(ExecutionContext exeContext) throws Exception
+ {
+ incrementCount();
exeContext.leaveNode();
}
- private static synchronized int incrementCount() {
+ private static synchronized int incrementCount()
+ {
return ++executionCount;
}
- public static synchronized int getExecutionCount() {
+ public static synchronized int getExecutionCount()
+ {
return executionCount;
}
}