Hi,
I have tried your process:
with a unit test:
Best Regards
Michael
I have tried your process:
<?xml version="1.0" encoding="UTF-8"?>
<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns
mgdc="http://www.omg.org/spec/DD/20100524/DC" xmlnsmgdi="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.activiti.org/test">
<process id="CheckForAFile" name="CheckForAFile">
<documentation>Process loops as long as variable 'fileExists' is false.</documentation>
<startEvent id="startevent1" name="Start"></startEvent>
<sequenceFlow id="flow1" name="" sourceRef="startevent1" targetRef="checkFileExists"></sequenceFlow>
<serviceTask id="checkFileExists" name="Check File Exists" activiti:class="com.bigfirm.CheckForFile"></serviceTask>
<exclusiveGateway id="exclusivegateway1" name="Exclusive Gateway"></exclusiveGateway>
<sequenceFlow id="flow2" name="" sourceRef="checkFileExists" targetRef="exclusivegateway1"></sequenceFlow>
<sequenceFlow id="doesExist" name="Yes" sourceRef="exclusivegateway1" targetRef="logThatFileExists">
<conditionExpression xsi:type="tFormalExpression"><![CDATA[${fileExists == true}]]></conditionExpression>
</sequenceFlow>
<scriptTask id="logThatFileExists" name="Log That File Exists" scriptFormat="groovy">
<script><![CDATA[print "File does exist. \n"]]></script>
</scriptTask>
<sequenceFlow id="fileNotExist" name="File Does Not Exist" sourceRef="exclusivegateway1" targetRef="logThatFileNotExist">
<conditionExpression xsi:type="tFormalExpression"><![CDATA[${fileExists != true}]]></conditionExpression>
</sequenceFlow>
<scriptTask id="logThatFileNotExist" name="Log That File Does Not Exist" scriptFormat="groovy">
<script><![CDATA[print "File does NOT exist. \n"]]></script>
</scriptTask>
<sequenceFlow id="flow3" name="" sourceRef="logThatFileExists" targetRef="endevent1"></sequenceFlow>
<intermediateCatchEvent id="waitAMinute" name="Wait one minutes">
<timerEventDefinition>
<timeDuration>PT1S</timeDuration>
</timerEventDefinition>
</intermediateCatchEvent>
<sequenceFlow id="flow4" name="" sourceRef="logThatFileNotExist" targetRef="waitAMinute"></sequenceFlow>
<sequenceFlow id="flow5" name="" sourceRef="waitAMinute" targetRef="checkFileExists"></sequenceFlow>
<endEvent id="endevent1" name="End"></endEvent>
</process>
</definitions>with a unit test:
…extends PluggableActivitiTestCase {
public void testLoopWaitForFile() {
Map<String, Object> variables = new HashMap<String, Object>();
variables.put("fileExists", false);
ProcessInstance pi = runtimeService
.startProcessInstanceByKey("CheckForAFile", variables);
assertNotNull(pi);
assertTrue(
"History is turned off",
config.getHistoryLevel() > ProcessEngineConfigurationImpl.HISTORYLEVEL_NONE);
/*
* assert process is in the wait state
*/
Execution execution = runtimeService.createExecutionQuery()
.processInstanceId(pi.getId()).activityId("waitAMinute")
.singleResult();
assertNotNull("Process is not in the wait state as expected.",
execution);
long startTime = System.currentTimeMillis();
boolean fileCreated = false;
File file = null;
while (pi != null && !fileCreated) {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
fail("Test was interrupted.");
}
if (System.currentTimeMillis() - startTime > 1000) {
file = new File("bin/com/…/res/testWaitForFile");
try {
file.createNewFile();
} catch (IOException e) {
fail("Unable to create new file.\n"
+ PrintHelper.getStackTrace(e));
}
try {
Thread.sleep(2 * 1000);
} catch (InterruptedException e) {
fail("Test was interrupted.");
}
fileCreated = true;
}
}
while(System.currentTimeMillis() - startTime < 3 * 60 * 1000){
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if (null != file) {
file.delete();
}
pi = runtimeService.createProcessInstanceQuery().singleResult();
HistoricProcessInstance hpi = historyService
.createHistoricProcessInstanceQuery().singleResult();
assertNull(pi);
assertNotNull(hpi);
assertEquals("End activity endevent1 not reached.", "endevent1",
hpi.getEndActivityId());
}
…
My delegate class:
public class CheckForFile implements JavaDelegate {
@Override
public void execute(DelegateExecution execution) throws Exception {
boolean fileExists = false;
URL resource = this.getClass().getClassLoader().getResource(
"com/…/res/testWaitForFile");
if (resource != null) {
File file = new File(resource.toURI());
if (file.exists()) {
fileExists = true;
}
}
//execution.setVariable("fileExists", fileExists);
}
}File does NOT exist.
File does NOT exist.
File does NOT exist.
File does NOT exist.
File does NOT exist. If I uncomment the line in the listener everything is working fine:execution.setVariable("fileExists", fileExists);The history tables then look like this:
SELECT * FROM ACT_HI_ACTINST;
ID_ PROC_DEF_ID_ PROC_INST_ID_ EXECUTION_ID_ ACT_ID_ ACT_NAME_ ACT_TYPE_ ASSIGNEE_ START_TIME_ END_TIME_ DURATION_
319 CheckForAFile:1:317 318 318 startevent1 Start startEvent null 2011-12-02 09:29:32.415 2011-12-02 09:29:32.415 0
322 CheckForAFile:1:317 318 318 checkFileExists Check File Exists serviceTask null 2011-12-02 09:29:32.415 2011-12-02 09:29:32.415 0
324 CheckForAFile:1:317 318 318 exclusivegateway1 Exclusive Gateway exclusiveGateway null 2011-12-02 09:29:32.415 2011-12-02 09:29:32.415 0
325 CheckForAFile:1:317 318 318 logThatFileNotExist Log That File Does Not Exist scriptTask null 2011-12-02 09:29:32.415 2011-12-02 09:29:32.43 15
328 CheckForAFile:1:317 318 318 checkFileExists Check File Exists serviceTask null 2011-12-02 09:30:32.467 2011-12-02 09:30:32.467 0
330 CheckForAFile:1:317 318 318 exclusivegateway1 Exclusive Gateway exclusiveGateway null 2011-12-02 09:30:32.467 2011-12-02 09:30:32.467 0
331 CheckForAFile:1:317 318 318 logThatFileNotExist Log That File Does Not Exist scriptTask null 2011-12-02 09:30:32.467 2011-12-02 09:30:32.498 31
334 CheckForAFile:1:317 318 318 checkFileExists Check File Exists serviceTask null 2011-12-02 09:31:32.535 2011-12-02 09:31:32.535 0
336 CheckForAFile:1:317 318 318 exclusivegateway1 Exclusive Gateway exclusiveGateway null 2011-12-02 09:31:32.535 2011-12-02 09:31:32.535 0
337 CheckForAFile:1:317 318 318 logThatFileExists Log That File Exists scriptTask null 2011-12-02 09:31:32.535 2011-12-02 09:31:32.551 16Best Regards
Michael
