Fixing async gateway test. With a serious change in the way optimistic locking handled

modules/activiti-engine/src/main/java/org/activiti/engine/impl/asyncexecutor/ExecuteAsyncRunnable.java

@@ -61,7 +61,12 @@ public class ExecuteAsyncRunnable implements Runnable {
                         optimisticLockingException.getMessage());
             }
 
+            commandExecutor.execute(new Command<Void>() {
+            	public Void execute(CommandContext commandContext) {
             		commandContext.getJobEntityManager().retryAsyncJob(job);
+            		return null;
+            	}
+			});
             return;
 
         } catch (Throwable t) {

modules/activiti-engine/src/main/java/org/activiti/engine/impl/persistence/entity/ExecutionEntityManager.java

@@ -23,6 +23,7 @@ import java.util.List;
 import java.util.Map;
 
 import org.activiti.engine.ActivitiObjectNotFoundException;
+import org.activiti.engine.ActivitiOptimisticLockingException;
 import org.activiti.engine.delegate.event.ActivitiEventType;
 import org.activiti.engine.delegate.event.impl.ActivitiEventBuilder;
 import org.activiti.engine.impl.ExecutionQueryImpl;
@@ -223,22 +224,6 @@ public class ExecutionEntityManager extends AbstractEntityManager<ExecutionEntit
         getDbSqlSession().update("updateExecutionTenantIdForDeployment", params);
     }
 
-    public void updateProcessInstanceLockTime(String processInstanceId) {
-        CommandContext commandContext = Context.getCommandContext();
-        Date expirationTime = commandContext.getProcessEngineConfiguration().getClock().getCurrentTime();
-        int lockMillis = commandContext.getProcessEngineConfiguration().getAsyncExecutor().getAsyncJobLockTimeInMillis();
-        GregorianCalendar lockCal = new GregorianCalendar();
-        lockCal.setTime(expirationTime);
-        lockCal.add(Calendar.MILLISECOND, lockMillis);
-
-        HashMap<String, Object> params = new HashMap<String, Object>();
-        params.put("id", processInstanceId);
-        params.put("lockTime", lockCal.getTime());
-        params.put("expirationTime", expirationTime);
-
-        getDbSqlSession().update("updateProcessInstanceLockTime", params);
-    }
-    
     
     
     // DELETE METHODS
@@ -294,6 +279,25 @@ public class ExecutionEntityManager extends AbstractEntityManager<ExecutionEntit
     
     // OTHER METHODS
     
+    public void updateProcessInstanceLockTime(String processInstanceId) {
+        CommandContext commandContext = Context.getCommandContext();
+        Date expirationTime = commandContext.getProcessEngineConfiguration().getClock().getCurrentTime();
+        int lockMillis = commandContext.getProcessEngineConfiguration().getAsyncExecutor().getAsyncJobLockTimeInMillis();
+        GregorianCalendar lockCal = new GregorianCalendar();
+        lockCal.setTime(expirationTime);
+        lockCal.add(Calendar.MILLISECOND, lockMillis);
+
+        HashMap<String, Object> params = new HashMap<String, Object>();
+        params.put("id", processInstanceId);
+        params.put("lockTime", lockCal.getTime());
+        params.put("expirationTime", expirationTime);
+
+        int result = getDbSqlSession().update("updateProcessInstanceLockTime", params);
+        if (result == 0) {
+        	throw new ActivitiOptimisticLockingException("JORAM123");
+        }
+    }
+    
 
     public void clearProcessInstanceLockTime(String processInstanceId) {
         HashMap<String, Object> params = new HashMap<String, Object>();

modules/activiti-engine/src/test/java/org/activiti/engine/test/bpmn/gateway/InclusiveGatewayTest.java

@@ -433,7 +433,7 @@ public class InclusiveGatewayTest extends PluggableActivitiTestCase {
     @Deployment
     public void testAsyncBehavior() {
         ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("async");
-        waitForJobExecutorToProcessAllJobs(500000000L, 5000L);
+        waitForJobExecutorToProcessAllJobs(5000L, 250);
         assertEquals(0, runtimeService.createProcessInstanceQuery().processInstanceId(processInstance.getId()).count());
     }
 

modules/activiti-engine/src/test/resources/org/activiti/engine/test/bpmn/gateway/InclusiveGatewayTest.testAsyncBehavior.bpmn20.xml

@@ -18,7 +18,7 @@
     <sequenceFlow id="flow2" sourceRef="fork" targetRef="task1" />
     <sequenceFlow id="flow3" sourceRef="fork" targetRef="task2" />
     
-    <inclusiveGateway id="join" activiti:async="true" />
+    <inclusiveGateway id="join" activiti:async="true" activiti:exclusive="true" />
     
     <sequenceFlow id="flow4" sourceRef="task1" targetRef="join" />
     <sequenceFlow id="flow5" sourceRef="task2" targetRef="join" />