topic problem unit testing with async=true in Alfresco Archive https://connect.hyland.com/t5/alfresco-archive/problem-unit-testing-with-async-true/m-p/148894#M103921 <HTML><HEAD></HEAD><BODY><SPAN>Hello, when running a simple test case and setting a service task to async it does not execute my Service class</SPAN><BR /><SPAN>This is the workflow:</SPAN><BR /><PRE class="language-none line-numbers"><CODE><BR />&lt;?xml version="1.0" encoding="UTF-8"?&gt;<BR />&lt;definitions xmlns="<A href="http://www.omg.org/spec/BPMN/20100524/MODEL" rel="nofollow noopener noreferrer">http://www.omg.org/spec/BPMN/20100524/MODEL</A>" xmlns:xsi="<A href="http://www.w3.org/2001/XMLSchema-instance" rel="nofollow noopener noreferrer">http://www.w3.org/2001/XMLSchema-instance</A>" xmlns:activiti="<A href="http://activiti.org/bpmn" rel="nofollow noopener noreferrer">http://activiti.org/bpmn</A>" xmlns:bpmndi="<A href="http://www.omg.org/spec/BPMN/20100524/DI" rel="nofollow noopener noreferrer">http://www.omg.org/spec/BPMN/20100524/DI</A>" xmlns:omgdc="<A href="http://www.omg.org/spec/DD/20100524/DC" rel="nofollow noopener noreferrer">http://www.omg.org/spec/DD/20100524/DC</A>" xmlns:omgdi="<A href="http://www.omg.org/spec/DD/20100524/DI" rel="nofollow noopener noreferrer">http://www.omg.org/spec/DD/20100524/DI</A>" typeLanguage="<A href="http://www.w3.org/2001/XMLSchema" rel="nofollow noopener noreferrer">http://www.w3.org/2001/XMLSchema</A>" expressionLanguage="<A href="http://www.w3.org/1999/XPath" rel="nofollow noopener noreferrer">http://www.w3.org/1999/XPath</A>" targetNamespace="<A href="http://www.activiti.org/test" rel="nofollow noopener noreferrer">http://www.activiti.org/test</A>"&gt;<BR />&nbsp; &lt;process id="myProcess" name="My process" isExecutable="true"&gt;<BR />&nbsp;&nbsp;&nbsp; &lt;startEvent id="startevent1" name="Start"&gt;&lt;/startEvent&gt;<BR />&nbsp;&nbsp;&nbsp; &lt;endEvent id="endevent1" name="End"&gt;&lt;/endEvent&gt;<BR />&nbsp;&nbsp;&nbsp; &lt;serviceTask id="servicetask1" name="Some Service" activiti:async="true" activiti:class="RunService"&gt;&lt;/serviceTask&gt;<BR />&nbsp;&nbsp;&nbsp; &lt;sequenceFlow id="flow1" sourceRef="startevent1" targetRef="servicetask1"&gt;&lt;/sequenceFlow&gt;<BR />&nbsp;&nbsp;&nbsp; &lt;sequenceFlow id="flow2" sourceRef="servicetask1" targetRef="endevent1"&gt;&lt;/sequenceFlow&gt;<BR />&nbsp; &lt;/process&gt;<BR />&nbsp; &lt;bpmndi:BPMNDiagram id="BPMNDiagram_myProcess"&gt;<BR />&nbsp;&nbsp;&nbsp; &lt;bpmndi:BPMNPlane bpmnElement="myProcess" id="BPMNPlane_myProcess"&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;bpmndi:BPMNShape bpmnElement="startevent1" id="BPMNShape_startevent1"&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;omgdc:Bounds height="35.0" width="35.0" x="290.0" y="130.0"&gt;&lt;/omgdc:Bounds&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/bpmndi:BPMNShape&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;bpmndi:BPMNShape bpmnElement="endevent1" id="BPMNShape_endevent1"&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;omgdc:Bounds height="35.0" width="35.0" x="600.0" y="130.0"&gt;&lt;/omgdc:Bounds&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/bpmndi:BPMNShape&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;bpmndi:BPMNShape bpmnElement="servicetask1" id="BPMNShape_servicetask1"&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;omgdc:Bounds height="55.0" width="105.0" x="420.0" y="120.0"&gt;&lt;/omgdc:Bounds&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/bpmndi:BPMNShape&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;bpmndi:BPMNEdge bpmnElement="flow1" id="BPMNEdge_flow1"&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;omgdi:waypoint x="325.0" y="147.0"&gt;&lt;/omgdi:waypoint&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;omgdi:waypoint x="420.0" y="147.0"&gt;&lt;/omgdi:waypoint&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/bpmndi:BPMNEdge&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;bpmndi:BPMNEdge bpmnElement="flow2" id="BPMNEdge_flow2"&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;omgdi:waypoint x="525.0" y="147.0"&gt;&lt;/omgdi:waypoint&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;omgdi:waypoint x="600.0" y="147.0"&gt;&lt;/omgdi:waypoint&gt;<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/bpmndi:BPMNEdge&gt;<BR />&nbsp;&nbsp;&nbsp; &lt;/bpmndi:BPMNPlane&gt;<BR />&nbsp; &lt;/bpmndi:BPMNDiagram&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 /><SPAN>This is the service class:</SPAN><BR /><BR /><PRE class="language-java line-numbers"><CODE><BR />import org.activiti.engine.impl.pvm.delegate.ActivityBehavior;<BR />import org.activiti.engine.impl.pvm.delegate.ActivityExecution;<BR /><BR /><BR />public class RunService implements ActivityBehavior {<BR /><BR />&nbsp;&nbsp;&nbsp;public void execute(ActivityExecution arg0) throws Exception {<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;System.out.println("executing RunService");<BR />&nbsp;&nbsp;&nbsp;}<BR />}<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></CODE></PRE><BR /><BR /><SPAN>and this is the unit test:</SPAN><BR /><PRE class="language-java line-numbers"><CODE><BR />package test.java.org.activiti.designer.test;<BR /><BR />import static org.junit.Assert.assertNotNull;<BR /><BR />import java.io.FileInputStream;<BR />import java.util.HashMap;<BR />import java.util.Map;<BR /><BR />import org.activiti.engine.RepositoryService;<BR />import org.activiti.engine.RuntimeService;<BR />import org.activiti.engine.runtime.ProcessInstance;<BR />import org.activiti.engine.test.ActivitiRule;<BR />import org.junit.Rule;<BR />import org.junit.Test;<BR /><BR />public class ProcessTestMyProcess {<BR /><BR />&nbsp;&nbsp;&nbsp;private String filename = "/resources/TestAsync.bpmn";<BR /><BR />&nbsp;&nbsp;&nbsp;@Rule<BR />&nbsp;&nbsp;&nbsp;public ActivitiRule activitiRule = new ActivitiRule();<BR /><BR />&nbsp;&nbsp;&nbsp;@Test<BR />&nbsp;&nbsp;&nbsp;public void startProcess() throws Exception {<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;RepositoryService repositoryService = activitiRule.getRepositoryService();<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;repositoryService.createDeployment().addInputStream("myProcess.bpmn20.xml",<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;new FileInputStream(filename)).deploy();<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;RuntimeService runtimeService = activitiRule.getRuntimeService();<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Map&lt;String, Object&gt; variableMap = new HashMap&lt;String, Object&gt;();<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;variableMap.put("name", "Activiti");<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("myProcess", variableMap);<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;assertNotNull(processInstance.getId());<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;System.out.println("id " + processInstance.getId() + " "<BR />&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;+ processInstance.getProcessDefinitionId());<BR />&nbsp;&nbsp;&nbsp;}<BR />}<BR /><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>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN><SPAN>‍</SPAN></SPAN></CODE></PRE><BR /><BR /><SPAN>When setting&nbsp; to activiti:async="true", the service class is never called (no println and no debugger breakpoint work here), setting it to false does make it get called. Am I misunderstanding how async should work here and is there a way for a unit test to work with async = true ?</SPAN><BR /><SPAN>Thank you. </SPAN><BR /></BODY></HTML> Fri, 14 Mar 2014 12:27:37 GMT gertp 2014-03-14T12:27:37Z problem unit testing with async=true https://connect.hyland.com/t5/alfresco-archive/problem-unit-testing-with-async-true/m-p/148894#M103921 Hello, when running a simple test case and setting a service task to async it does not execute my Service classThis is the workflow:&lt;?xml version="1.0" encoding="UTF-8"?&gt;&lt;definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xm Fri, 14 Mar 2014 12:27:37 GMT https://connect.hyland.com/t5/alfresco-archive/problem-unit-testing-with-async-true/m-p/148894#M103921 gertp 2014-03-14T12:27:37Z Re: problem unit testing with async=true https://connect.hyland.com/t5/alfresco-archive/problem-unit-testing-with-async-true/m-p/148895#M103922 <HTML><HEAD></HEAD><BODY><SPAN>Probably your job executor is not enabled: your process engine config needs to enable that.</SPAN><BR /><BR /><SPAN>Also: in your unit test you will need to wait for the job executor to pick it up (it polls the db every xx seconds). See other unit tests in the activiti-engine module around that.</SPAN></BODY></HTML> Mon, 17 Mar 2014 10:10:38 GMT https://connect.hyland.com/t5/alfresco-archive/problem-unit-testing-with-async-true/m-p/148895#M103922 jbarrez 2014-03-17T10:10:38Z