[jbpm-commits] JBoss JBPM SVN: r6059 - jbpm3/branches/jbpm-3.2-soa/modules/core/src/test/java/org/jbpm/jbpm983.

[do-not-reply at jboss.org]

Author: alex.guizar at jboss.com
Date: 2010-01-06 09:28:03 -0500 (Wed, 06 Jan 2010)
New Revision: 6059

Modified:
   jbpm3/branches/jbpm-3.2-soa/modules/core/src/test/java/org/jbpm/jbpm983/JBPM983Test.java
Log:
JBPM-2691: investigate mssql regression in JBPM983Test

Modified: jbpm3/branches/jbpm-3.2-soa/modules/core/src/test/java/org/jbpm/jbpm983/JBPM983Test.java
===================================================================
--- jbpm3/branches/jbpm-3.2-soa/modules/core/src/test/java/org/jbpm/jbpm983/JBPM983Test.java	2010-01-06 10:59:08 UTC (rev 6058)
+++ jbpm3/branches/jbpm-3.2-soa/modules/core/src/test/java/org/jbpm/jbpm983/JBPM983Test.java	2010-01-06 14:28:03 UTC (rev 6059)
@@ -1,8 +1,5 @@
 package org.jbpm.jbpm983;
 
-import java.util.Collections;
-import java.util.Map;
-
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
@@ -34,8 +31,6 @@
     jbpmContext.deployProcessDefinition(processDefinition);
     processDefinitionId = processDefinition.getId();
 
-    newTransaction();
-
     String dialect = getHibernateDialect();
     if (dialect.indexOf("DB2") == -1 // [JBPM-2115] multiple threads not supported on DB2 < 9.7
         && dialect.indexOf("HSQL") == -1) { // multiple threads will not be supported on HSQL
@@ -109,24 +104,21 @@
       + "</end-state>"
       + "</process-definition>";
 
-  public void testConcurrentJobs() throws Exception {
-    // create test properties
-    Map testVariables = Collections.singletonMap("test", "true");
+  static final int PROCESS_COUNT = 10;
 
-    final int processCount = 10;
-    long[] processInstanceIds = new long[processCount];
-    for (int i = 0; i < processCount; i++) {
+  public void testConcurrentJobs() throws Exception {
+    long[] processInstanceIds = new long[PROCESS_COUNT];
+    for (int i = 0; i < PROCESS_COUNT; i++) {
+      newTransaction();
       ProcessInstance processInstance = jbpmContext.newProcessInstanceForUpdate("superprocess");
-      processInstance.getContextInstance().addVariables(testVariables);
+      processInstance.getContextInstance().setVariable("test", "true");
       processInstance.signal();
       processInstanceIds[i] = processInstance.getId();
-
-      newTransaction();
     }
 
     processJobs(5 * 60 * 1000);
 
-    for (int i = 0; i < processCount; i++) {
+    for (int i = 0; i < PROCESS_COUNT; i++) {
       long piId = processInstanceIds[i];
       ProcessInstance pi = jbpmContext.loadProcessInstance(piId);
       assertEquals("end-state-success", pi.getRootToken().getNode().getName());
@@ -140,8 +132,7 @@
     private static final long serialVersionUID = 1L;
 
     public void execute(ExecutionContext executionContext) throws Exception {
-      String process = executionContext.getProcessDefinition().getName()
-          + ":"
+      String process = executionContext.getProcessDefinition().getName() + ':'
           + executionContext.getProcessInstance().getId();
       String node = executionContext.getNode().getName();
       String token = executionContext.getToken().toString();