学步园

// 这里的代码可以放在消息驱动Bean里面。

  // 让我们开始一个session
  JbpmSession jbpmSession = jbpmSessionFactory.openJbpmSession();
  // 在持久化session上开始一个事务的时候，这里有可使用WEB应用中的DataSource来取得一个数据库session.
  jbpmSession.beginTransaction();
  GraphSession graphSession = jbpmSession.getGraphSession();

  // 首先，我们需要在数据库中把流程提取出来.
  // 这里有很多方法可以用来取得我们需要的流程实例。
  // 一个最简单方法就是在流程的实例列表里面查询。
  ProcessDefinition processDefinition = graphSession
    .findLatestProcessDefinition("hello world");

  // 现在查询所有的流程实例。
  List<ProcessInstance> processInstances = graphSession
    .findProcessInstances(processDefinition.getId());

  // 我们知道在这里单元测试里面只有一个执行，所以下面我们直接get(0)。
  // 而在实际工作中，我们这里需要通过ID来确定我们所需要的流程实例。
  ProcessInstance processInstance = null;
  for (ProcessInstance pi : processInstances) {

   if (!pi.hasEnded()) {
    pi.signal();
    //AssertJUnit.assertTrue(pi.hasEnded());
   } 

 }

  // 好了，现在我们可以继续执行。注意，这里processInstance
  // processInstance.signal();

  // 完成signal以后，我们的流程就到达end-state状态点了。
  // AssertJUnit.assertTrue(processInstance.hasEnded());

  // 现在可以更新数据库里面流程状态点。
  // graphSession.saveProcessInstance(processInstance);

  // 事务提交
  jbpmSession.commitTransaction();
  // 关闭session
  jbpmSession.close();