Unit testing processes with async tasks

As we transition to the new Hyland Community, some post links may be temporarily disrupted as we finalize redirects. We apologize for the inconvenience and are working to resolve this as quickly as possible. Details.

imbaczek

Hello,

This process' script1 task executes just fine in a unit test.

   <process id="my-process">

      <startEvent id="start" />
      <sequenceFlow id="flow1" sourceRef="start" targetRef="script1" />

      <scriptTask id="script1"
         name="log" scriptFormat="groovy" activiti:autoStoreVariables="false">
         <script>println("my-process-test-output")</script>
      </scriptTask>
      <sequenceFlow id="flow2" sourceRef="script1" targetRef="end" />

      <endEvent id="end" />

   </process>‍‍‍‍‍‍‍‍‍‍‍‍‍‍

   
But when I set activiti:async="true" in script1, the script doesn't execute, which is kind of expected. What to do to make it work? I need to unit test long-running scripts (waiting for external program output.)

martin_grofcik

Hello,

you can have a look on the following jUnit test
<br>&nbsp; @Deployment<br>&nbsp; public void testAsycServiceNoListeners() {&nbsp; <br>&nbsp;&nbsp;&nbsp; INVOCATION = false;<br>&nbsp;&nbsp;&nbsp; // start process <br>&nbsp;&nbsp;&nbsp; runtimeService.startProcessInstanceByKey("asyncService");<br>&nbsp;&nbsp;&nbsp; // now there should be one job in the database:<br>&nbsp;&nbsp;&nbsp; assertEquals(1, managementService.createJobQuery().count());<br>&nbsp;&nbsp;&nbsp; // the service was not invoked:<br>&nbsp;&nbsp;&nbsp; assertFalse(INVOCATION);<br>&nbsp;&nbsp;&nbsp; <br>&nbsp;&nbsp;&nbsp; waitForJobExecutorToProcessAllJobs(10000L, 25L);<br>&nbsp;&nbsp;&nbsp; <br>&nbsp;&nbsp;&nbsp; // the service was invoked<br>&nbsp;&nbsp;&nbsp; assertTrue(INVOCATION);&nbsp;&nbsp;&nbsp; <br>&nbsp;&nbsp;&nbsp; // and the job is done<br>&nbsp;&nbsp;&nbsp; assertEquals(0, managementService.createJobQuery().count());&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <br>&nbsp; }<br>
the process is:
<br>&nbsp; <process id="asyncService"><br>&nbsp; <br>&nbsp;&nbsp;&nbsp; <startEvent id="theStart" /><br>&nbsp;&nbsp;&nbsp; <sequenceFlow id="flow1" sourceRef="theStart" targetRef="service" /><br>&nbsp;&nbsp;&nbsp; <br>&nbsp;&nbsp;&nbsp; <serviceTask id="service" activiti:class="org.activiti.engine.test.bpmn.async.AsyncService" activiti:async="true" /><br>&nbsp;&nbsp;&nbsp; <br>&nbsp;&nbsp;&nbsp; <sequenceFlow id="flow2" sourceRef="service" targetRef="theEnd" /><br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <br>&nbsp;&nbsp;&nbsp; <endEvent id="theEnd" /><br>&nbsp;&nbsp;&nbsp; <br>&nbsp; </process><br>
Regards
Martin