topic Make part of an Execution asynchronous in Alfresco Archive https://connect.hyland.com/t5/alfresco-archive/make-part-of-an-execution-asynchronous/m-p/245528#M198658 <HTML><HEAD></HEAD><BODY><SPAN>Hello, i have the following use case:</SPAN><BR /><BR /><SPAN>I have a Process that is accessed and worked on via webapp.</SPAN><BR /><BR /><SPAN>A process starts wit a user-task, where a user has to input some data, then submit the form. This is followed by 3 short service tasks, followed by another Form, where the user can review the manipulations made by the service tasks.</SPAN><BR /><BR /><SPAN>This has to happen synchronous, meaning the user will click "submit" in the first form and wait for the rpocess to reach the second form for imediate feedback.</SPAN><BR /><BR /><SPAN>When the second task is submitted, it is followed by ~20 service tasks, followed by a closing usertask for final approval.</SPAN><BR /><BR /><SPAN>Here i do NOT want the user to wait for the service-tasks to finish, but for the engine to return control the the main thread and have the application poll the engine for "final tasks". I cannot get activiti to continue along the path that i need to be asynchronous somehow.</SPAN><BR /><BR /><SPAN>the process shortened for better understanding:</SPAN><BR /><BR /><PRE class="language-none line-numbers"><CODE><BR />&lt;definitions xmlns="http:…"&gt;<BR />&nbsp; &lt;process id="test_process_2" isClosed="false" isExecutable="true" processType="None"&gt;<BR />&nbsp; <BR />&nbsp; <BR /> <BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;startEvent id="start" name="StartEvent"/&gt;<BR />&nbsp;&nbsp;&nbsp; <BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;userTask activiti:async="false" activiti:exclusive="true" id="input_data" name="enter initial data"&gt;&lt;/userTask&gt;<BR />&nbsp;&nbsp;&nbsp;<BR />&nbsp;&nbsp;&nbsp;&lt;serviceTask activiti:async="false" activiti:class="ShortRunningTasks" <BR />&nbsp;&nbsp;&nbsp;activiti:exclusive="true" id="feedback_service" name="giving imediate feedback"/&gt;<BR />&nbsp;&nbsp;&nbsp;<BR />&nbsp;&nbsp;&nbsp;&lt;userTask activiti:async="false" activiti:exclusive="true" id="feedback" name="giving feedback"&gt;&lt;/userTask&gt;<BR /> <BR /><BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;serviceTask activiti:async="true" activiti:class="LongRunningTasks" <BR />&nbsp;&nbsp;&nbsp;activiti:exclusive="true" id="longrunning" name="a lot of small tasks that in sum take a relatively long time"/&gt;<BR />&nbsp;&nbsp;&nbsp;<BR />&nbsp;&nbsp;&nbsp;&lt;userTask activiti:async="false" activiti:exclusive="true" id="final_approval" name="review and end process"&gt;&lt;/userTask&gt;<BR />&nbsp;&nbsp;&nbsp;<BR />&nbsp;&nbsp;&nbsp;&lt;endEvent id="end" name="EndEvent"/&gt;<BR />&nbsp;&nbsp;&nbsp;<BR /><BR />&nbsp;&nbsp;&nbsp;&lt;sequenceFlow id="flow1" sourceRef="start" targetRef="input_data"/&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;sequenceFlow id="flow2" sourceRef="input_data" targetRef="feedback_service"/&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;sequenceFlow id="flow3" sourceRef="feedback_service" targetRef="feedback"/&gt;<BR />&nbsp;&nbsp;&nbsp;&lt;sequenceFlow id="flow3" sourceRef="feedback" targetRef="longrunning"/&gt;<BR />&nbsp;&nbsp;&nbsp;&lt;sequenceFlow id="flow4" sourceRef="longrunning" targetRef="final_approval"/&gt;<BR />&nbsp;&nbsp;&nbsp;&lt;sequenceFlow id="flow5" sourceRef="final_approval" targetRef="end"/&gt;<BR />&nbsp; &lt;/process&gt;<BR />&lt;/definitions&gt;<BR /><SPAN class="line-numbers-rows"><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN></SPAN></CODE></PRE><BR /><BR /><BR /><BR /><SPAN>A Testcase on this somehow "stops" at the longrunning task placeholder.</SPAN><BR /><BR /><SPAN>activiti.cfg.xml</SPAN><BR /><PRE class="language-none line-numbers"><CODE><BR />&nbsp; &lt;bean id="processEngineConfiguration" class="org.activiti.engine.impl.cfg.StandaloneInMemProcessEngineConfiguration"&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name="jdbcUrl" value="jdbc:h2:mem:activiti;DB_CLOSE_DELAY=1000" /&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name="jdbcDriver" value="org.h2.Driver" /&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name="jdbcUsername" value="sa" /&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name="jdbcPassword" value="" /&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name="jobExecutorActivate" value="false" /&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name="asyncExecutor" ref="asyncExecutor" /&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name="asyncExecutorEnabled" value="true" /&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name="asyncExecutorActivate" value="false" /&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name="defaultFailedJobWaitTime" value="1" /&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name="asyncFailedJobWaitTime" value="1" /&gt;<BR />&nbsp;&nbsp;&nbsp; &lt;/bean&gt;<BR />&nbsp;&nbsp;&nbsp; &lt;bean id="asyncExecutor" class="org.activiti.engine.impl.asyncexecutor.DefaultAsyncJobExecutor"&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name="defaultAsyncJobAcquireWaitTimeInMillis" value="500" /&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name="defaultTimerJobAcquireWaitTimeInMillis" value="500" /&gt;<BR />&nbsp;&nbsp;&nbsp; &lt;/bean&gt;<BR /><SPAN class="line-numbers-rows"><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN></SPAN></CODE></PRE><BR /><BR /><SPAN>The testcase:</SPAN><BR /><PRE class="language-none line-numbers"><CODE><BR />@Rule<BR />&nbsp;&nbsp;&nbsp; public ActivitiRule activitiRule = new ActivitiRule();<BR /><BR />&nbsp;&nbsp;&nbsp; // also tried activitiRule instead of&nbsp; ProcessEngines.getDefaultprocessEngine()<BR /><BR />&nbsp;&nbsp;&nbsp; @Test<BR />&nbsp;&nbsp;&nbsp; @Deployment(resources = {"test_process_2.bpmn"})<BR />&nbsp;&nbsp;&nbsp; public void test() throws InterruptedException {<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ProcessInstance processInstance = activitiRule.getRuntimeService().startProcessInstanceByKey("test_process_2");<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Task task = ProcessEngines.getDefaultProcessEngine().getTaskService().createTaskQuery().singleResult();<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ProcessEngines.getDefaultProcessEngine().getFormService().submitTaskFormData(task.getId(), new SimpleInitMap&lt;String, String&gt;("text", "blahblah"));<BR /><BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Boolean b =true;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; while(b) {<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; List&lt;Execution&gt; executions = ProcessEngines.getDefaultProcessEngine().getRuntimeService().createExecutionQuery().processInstanceId(processInstance.getProcessInstanceId()).list();<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; b = executions.get(0).getActivityId().equals("longrunning");<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println(executions.size() + " execution(s) online, waiting…");<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread.sleep(1000);<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }<BR />&nbsp;&nbsp;&nbsp; }<BR /><SPAN class="line-numbers-rows"><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN></SPAN></CODE></PRE><BR /><BR /><BR /><SPAN>the unittest keeps running in the loop, meaning the only execution is standing on "longrunning". the task consists only of writing 1.000 "a" ta file, after 10 minutes, neither s file is present, nor has the process continued to the final-task.</SPAN><BR /><BR /><SPAN>a "jobquery" gives me one job for the processInstance-id named "async-continuation". But nothing happens.</SPAN><BR /><BR /><SPAN>I have the feeling i am using "async" and "exclusive" wrong somehow. Can someone help please?</SPAN></BODY></HTML> Fri, 18 Nov 2016 10:09:40 GMT billdoor 2016-11-18T10:09:40Z Make part of an Execution asynchronous https://connect.hyland.com/t5/alfresco-archive/make-part-of-an-execution-asynchronous/m-p/245528#M198658 Hello, i have the following use case:I have a Process that is accessed and worked on via webapp.A process starts wit a user-task, where a user has to input some data, then submit the form. This is followed by 3 short service tasks, followed by another Form, where the user can review the manipulation Fri, 18 Nov 2016 10:09:40 GMT https://connect.hyland.com/t5/alfresco-archive/make-part-of-an-execution-asynchronous/m-p/245528#M198658 billdoor 2016-11-18T10:09:40Z Re: Make part of an Execution asynchronous https://connect.hyland.com/t5/alfresco-archive/make-part-of-an-execution-asynchronous/m-p/245529#M198659 <HTML><HEAD></HEAD><BODY><SPAN>Hi BillDoor!</SPAN><BR /><SPAN>According to your config, asyncExecutor is enabled, but not activated. </SPAN><BR /><SPAN>Set asyncExecutorActivate=true</SPAN><BR /><BR /><SPAN>Also, there is JobTestHelper.waitForJobExecutorToProcessAllJobs that can help waiting for all jobs finished in test. </SPAN><BR /><SPAN>&lt;code&gt;</SPAN><BR /><SPAN>package org.activiti.engine.impl.test;</SPAN><BR /><BR /><SPAN>JobTestHelper.waitForJobExecutorToProcessAllJobs(this.processEngineConfiguration, this.managementService, maxMillisToWait, intervalMillis);</SPAN><BR /><SPAN>&lt;/code&gt;</SPAN></BODY></HTML> Fri, 18 Nov 2016 13:05:07 GMT https://connect.hyland.com/t5/alfresco-archive/make-part-of-an-execution-asynchronous/m-p/245529#M198659 warper 2016-11-18T13:05:07Z