Job executor在jbpm.cfg.xml中是被缺省注释的,所以只要去掉此行即可通过JobExecutor来定时触发timer中的event-handler了
<jbpm-configuration>
<import resource="jbpm.default.cfg.xml" />
<import resource="jbpm.businesscalendar.cfg.xml" />
<import resource="jbpm.tx.hibernate.cfg.xml" />
<import resource="jbpm.jpdl.cfg.xml" />
<import resource="jbpm.bpmn.cfg.xml" />
<import resource="jbpm.identity.cfg.xml" />
<!-- Job executor is excluded for running the example test cases. -->
<!-- To enable timers and messages in production use, this should be included. -->
<import resource="jbpm.jobexecutor.cfg.xml" />
</jbpm-configuration>
测试程序
/**
* @author hzhlu
*/
public class CopyOfTimerRepeatTest extends JbpmTestCase {
String deploymentId;
protected void setUp() throws Exception {
super.setUp();
deploymentId = repositoryService.createDeployment().addResourceFromClasspath(
"org/jbpm/examples/timer/repeat/process.jpdl.xml").deploy();
}
protected void tearDown() throws Exception {
repositoryService.deleteDeploymentCascade(deploymentId);
super.tearDown();
}
public void testTimerRepeat() {
ProcessInstance processInstance = executionService.startProcessInstanceByKey("TimerRepeat");
// 查询进入状态后是否已经建立起timer job
Job job = managementService.createJobQuery().processInstanceId(processInstance.getId()).uniqueResult();
System.out.println("job info:" + job.getDueDate() + " " + job.toString());
assertNull(executionService.getVariable(processInstance.getId(), "escalations"));
String msg;
for (int i = 0; i < 10; i++) {
long difference = job.getDueDate().getTime() - System.currentTimeMillis();
msg = "Job触发倒计时: " + difference + " check escalations:"
+ executionService.getVariable(processInstance.getId(), "escalations");
System.out.println(">>> " + msg);
// 延时1秒
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
JPDL 定义文件,3秒钟后触发,然后每隔5秒再触发事件
<?xml version="1.0" encoding="UTF-8"?>
<process name="TimerRepeat" xmlns="http://jbpm.org/4.4/jpdl">
<start g="19,50,48,48">
<transition to="guardedWait" />
</start>
<state name="guardedWait" g="98,46,127,52">
<on event="timeout1">
<timer duedate="3 seconds" repeat="5 seconds" />
<event-listener class="org.jbpm.examples.timer.repeat.Escalate" />
</on>
<transition name="go on" to="next step" g="-16,-17"/>
</state>
<state name="next step" g="283,46,83,53"/>
</process>
事件处理程序
public class Escalate implements EventListener {
private static final long serialVersionUID = 1L;
public void notify(EventListenerExecution execution) {
System.out.println("Escalate.notify()");
Integer escalations = (Integer) execution.getVariable("escalations");
if (escalations == null) {
execution.setVariable("escalations", 1);
} else {
execution.setVariable("escalations", escalations + 1);
}
}
}
执行结果
job info:2010-07-27 14:55:43.0 timer[9|2010-07-27 14:55:43|timeout1]
>>> Job触发倒计时: 2907 check escalations:null
>>> Job触发倒计时: 1907 check escalations:null
>>> Job触发倒计时: 891 check escalations:null
Escalate.notify()
>>> Job触发倒计时: -109 check escalations:1
>>> Job触发倒计时: -1125 check escalations:1
>>> Job触发倒计时: -2125 check escalations:1
>>> Job触发倒计时: -3125 check escalations:1
>>> Job触发倒计时: -4140 check escalations:1
Escalate.notify()
>>> Job触发倒计时: -5140 check escalations:2
>>> Job触发倒计时: -6140 check escalations:2
分享到:
相关推荐
JBPM中 使用JobExecutor执行timer定义的job 使用此处中转,别人的资料。工作使用。
jBPM教学视屏(02管理流程定义)。。。。。。。。。
jbpm中文用户指南,涵盖jbpm所有内容!
jBPM 4视频教程02管理流程定义,如何定义流程
jbpm中文帮助文档
JBPM采购申请系统——20_JBPM4.0使用及特性.7z JBPM采购申请系统——20_JBPM4.0使用及特性.7z JBPM采购申请系统——20_JBPM4.0使用及特性.7z JBPM采购申请系统——20_JBPM4.0使用及特性.7z JBPM采购申请系统——20_...
在整个流程实例运行过程中,我们可以迅速的利用token得到其当前的current state。在解决“并行”等(比如Fork)问题时,jBpm让Token对象维护了父子关系,这种关系在涉及到Fork的时候会产生。 jBpm让Token这个对象身...
文档包括程序的安装,以及...jBPM 用户手册 第一章 概述 第二章 安装 第三章 流程 - 第四章 BPMN2.0 - 第五章 API - 第六章 人工任务 - 第七章 领域 - 规范流程 - 第八章 持久化 - 第九章 控制台 - 第十章 监视 -
详细分析解释JBPM工作流API 内含丰富示例截图 代码
1.6 JBPM_DELEGATION:流程代理类表(用于实例化jbpm中的action类) 6 1.7 JBPM_TASK:流程任务表 6 1.8 JBPM_TASKCONTROLLER:流程任务控制器 7 1.9 JBPM_VARIABLEACCESS:流程变量表 7 1.10 JBPM_MODULEDEFINITION...
一本比较使用帮助关于jbpm的书。好用好用
定义jBPM用户库 2.11.5. 在目录中添加jPDL4模式 2.11.6. 导入示例 2.11.7. 使用ant添加部分文件 3. 流程设计器(GPD) 3.1. 创建一个新的流程文件 3.2. 编辑流程文件的源码 4. 部署业务归档 4.1. 部署...
jbpm一个简单示例,采用structs+jbpm实现的一个报销流程。是一个入门的好例子,有兴趣的朋友可以看看
NULL 博文链接:https://windspy.iteye.com/blog/328112
把jBPM安装到JBoss中。 安装hsqldb,并在后台启动。 创建数据库结构 在后台启动JBoss 根据示例创建一个examples.bar业务归档,把它发布到jBPM数据库中 从${jbpm.home}/install/src/demo/example.identities....
jbpm介绍jbpm介绍jbpm介绍jbpm介绍jbpm介绍jbpm介绍jbpm介绍jbpm介绍jbpm介绍jbpm介绍jbpm介绍jbpm介绍
5.12 表JBPM4_JOB 13 5.13 表JBPM4_LOB 14 5.14 表JBPM4_PARTICIPATION 15 5.15 表JBPM4_PROPERTY 15 5.16 表JBPM4_SWIMLANE 15 5.17 表JBPM4_TASK 16 5.18 表JBPM4_VARIABLE 17 6、操作: 19 6.1 发布一个流程...
使用JBoss jBPM实现流程访问和执行的授权
JBPM采购申请系统——07_JBPM中的脚本语言.7z JBPM采购申请系统——07_JBPM中的脚本语言.7z JBPM采购申请系统——07_JBPM中的脚本语言.7z JBPM采购申请系统——07_JBPM中的脚本语言.7z JBPM采购申请系统——07_JBPM...
JBPM工作流实战_流程定义文件的上传处理视频