Author: mputz Date: 2011-03-30 05:44:26 -0400 (Wed, 30 Mar 2011) New Revision: 6911 Added: jbpm3/branches/jbpm-3.2-soa/core/src/test/resources/org/jbpm/graph/node/sub-process-async.cfg.xml Modified: jbpm3/branches/jbpm-3.2-soa/core/src/main/java/org/jbpm/graph/exe/ProcessInstance.java jbpm3/branches/jbpm-3.2-soa/core/src/main/java/org/jbpm/graph/node/ProcessState.java jbpm3/branches/jbpm-3.2-soa/core/src/main/resources/org/jbpm/default.jbpm.cfg.xml jbpm3/branches/jbpm-3.2-soa/core/src/test/java/org/jbpm/graph/exe/SubProcessPlusConcurrencyDbTest.java Log: JBPM-3151: Restore synchronous signaling behavior for sub-processes Modified: jbpm3/branches/jbpm-3.2-soa/core/src/main/java/org/jbpm/graph/exe/ProcessInstance.java =================================================================== --- jbpm3/branches/jbpm-3.2-soa/core/src/main/java/org/jbpm/graph/exe/ProcessInstance.java 2011-03-29 16:00:35 UTC (rev 6910) +++ jbpm3/branches/jbpm-3.2-soa/core/src/main/java/org/jbpm/graph/exe/ProcessInstance.java 2011-03-30 09:44:26 UTC (rev 6911) @@ -30,6 +30,7 @@ import java.util.List; import java.util.Map; +import org.jbpm.JbpmConfiguration.Configs; import org.jbpm.JbpmContext; import org.jbpm.JbpmException; import org.jbpm.context.exe.ContextInstance; @@ -328,7 +329,7 @@ if (superProcessToken != null && !superProcessToken.hasEnded()) { // is message service available? MessageService messageService; - if (jbpmContext != null + if (jbpmContext != null && Configs.getBoolean("jbpm.sub.process.async") && (messageService = jbpmContext.getServices().getMessageService()) != null) { // signal super-process token asynchronously to avoid stale state exceptions // due to concurrent signals to the super-process Modified: jbpm3/branches/jbpm-3.2-soa/core/src/main/java/org/jbpm/graph/node/ProcessState.java =================================================================== --- jbpm3/branches/jbpm-3.2-soa/core/src/main/java/org/jbpm/graph/node/ProcessState.java 2011-03-29 16:00:35 UTC (rev 6910) +++ jbpm3/branches/jbpm-3.2-soa/core/src/main/java/org/jbpm/graph/node/ProcessState.java 2011-03-30 09:44:26 UTC (rev 6911) @@ -193,7 +193,7 @@ // send the signal to start the subprocess JbpmContext jbpmContext = JbpmContext.getCurrentJbpmContext(); MessageService messageService; - if (jbpmContext != null + if (jbpmContext != null && Configs.getBoolean("jbpm.sub.process.async") && (messageService = jbpmContext.getServices().getMessageService()) != null) { // signal sub-process token asynchronously to clearly denote transactional boundaries // https://jira.jboss.org/browse/JBPM-2948 Modified: jbpm3/branches/jbpm-3.2-soa/core/src/main/resources/org/jbpm/default.jbpm.cfg.xml =================================================================== --- jbpm3/branches/jbpm-3.2-soa/core/src/main/resources/org/jbpm/default.jbpm.cfg.xml 2011-03-29 16:00:35 UTC (rev 6910) +++ jbpm3/branches/jbpm-3.2-soa/core/src/main/resources/org/jbpm/default.jbpm.cfg.xml 2011-03-30 09:44:26 UTC (rev 6911) @@ -64,6 +64,9 @@ <bean name="jbpm.sub.process.resolver" class="org.jbpm.graph.node.DbSubProcessResolver" singleton="true" /> + <boolean name="jbpm.sub.process.async" value="false" /> + + <bean name="jbpm.expression.evaluator" class="org.jbpm.jpdl.el.impl.ExpressionEvaluatorImpl" singleton="true" /> <bean name="jbpm.variable.resolver" class="org.jbpm.jpdl.el.impl.JbpmVariableResolver" Modified: jbpm3/branches/jbpm-3.2-soa/core/src/test/java/org/jbpm/graph/exe/SubProcessPlusConcurrencyDbTest.java =================================================================== --- jbpm3/branches/jbpm-3.2-soa/core/src/test/java/org/jbpm/graph/exe/SubProcessPlusConcurrencyDbTest.java 2011-03-29 16:00:35 UTC (rev 6910) +++ jbpm3/branches/jbpm-3.2-soa/core/src/test/java/org/jbpm/graph/exe/SubProcessPlusConcurrencyDbTest.java 2011-03-30 09:44:26 UTC (rev 6911) @@ -27,6 +27,10 @@ import org.jbpm.graph.def.ProcessDefinition; public class SubProcessPlusConcurrencyDbTest extends AbstractDbTestCase { + + protected String getJbpmTestConfig() { + return "org/jbpm/graph/node/sub-process-async.cfg.xml"; + } protected void setUp() throws Exception { super.setUp(); Added: jbpm3/branches/jbpm-3.2-soa/core/src/test/resources/org/jbpm/graph/node/sub-process-async.cfg.xml =================================================================== --- jbpm3/branches/jbpm-3.2-soa/core/src/test/resources/org/jbpm/graph/node/sub-process-async.cfg.xml (rev 0) +++ jbpm3/branches/jbpm-3.2-soa/core/src/test/resources/org/jbpm/graph/node/sub-process-async.cfg.xml 2011-03-30 09:44:26 UTC (rev 6911) @@ -0,0 +1,5 @@ +<?xml version="1.0" encoding="UTF-8" ?> + +<jbpm-configuration> + <boolean name="jbpm.sub.process.async" value="true" /> +</jbpm-configuration> \ No newline at end of file