Package org.activiti.engine

Examples of org.activiti.engine.RuntimeService

23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
              .buildProcessEngine();
   
    System.out.println("engine version: "+eng.VERSION);
   
    RepositoryService repoSvc = eng.getRepositoryService();
    RuntimeService rtSvc = eng.getRuntimeService();
   
    String wfn = "/diagrams/ScriptScript.bpmn";
    String wffn = wfn+"20.xml"; // workaround for http://forums.activiti.org/en/viewtopic.php?f=8&t=3745&start=10
        DeploymentBuilder db = repoSvc
                 .createDeployment()
                 .addInputStream(wffn,this.getClass().getResourceAsStream(wfn));
   
        Deployment d = db.deploy();
        ProcessDefinition pDef = repoSvc
                                 .createProcessDefinitionQuery()
                                 .deploymentId(d.getId())
                                 .singleResult();

        ProcessInstance proc = rtSvc.startProcessInstanceById(pDef.getId());
       
        String procId = proc.getId();
        System.out.println("procId="+procId);
       
        long timeout = System.currentTimeMillis()+15*1000;
 
View Full Code Here
25
26
27
28
29
30
31
32
33
34
35
36
37
38
  @Test
  public void startProcess() throws Exception {
    RepositoryService repositoryService = activitiRule.getRepositoryService();
    repositoryService.createDeployment().addInputStream("expression.bpmn20.xml",
        new FileInputStream(filename)).deploy();
    RuntimeService runtimeService = activitiRule.getRuntimeService();
    Map<String, Object> variableMap = new HashMap<String, Object>();
    variableMap.put("name", "Activiti");
    variableMap.put("printer", new Printer());
    ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("expression", variableMap);
    assertNotNull(processInstance.getId());
    System.out.println("id " + processInstance.getId() + " "
        + processInstance.getProcessDefinitionId());
  }
View Full Code Here
23
24
25
26
27
28
29
30
31
32
33
34
35
  @Test
  public void startProcess() throws Exception {
    RepositoryService repositoryService = activitiRule.getRepositoryService();
    repositoryService.createDeployment().addInputStream("effectInsurance.bpmn20.xml",
        new FileInputStream(filename)).deploy();
    RuntimeService runtimeService = activitiRule.getRuntimeService();
    Map<String, Object> variableMap = new HashMap<String, Object>();
    variableMap.put("name", "Activiti");
    ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("effectInsurance", variableMap);
    assertNotNull(processInstance.getId());
    System.out.println("id " + processInstance.getId() + " "
        + processInstance.getProcessDefinitionId());
  }
View Full Code Here
23
24
25
26
27
28
29
30
31
32
33
34
35
  @Test
  public void startProcess() throws Exception {
    RepositoryService repositoryService = activitiRule.getRepositoryService();
    repositoryService.createDeployment().addInputStream("ErrorEventAndRerun.bpmn20.xml",
        new FileInputStream(filename)).deploy();
    RuntimeService runtimeService = activitiRule.getRuntimeService();
    Map<String, Object> variableMap = new HashMap<String, Object>();
    variableMap.put("name", "Activiti");
    ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("ErrorEventAndRerun", variableMap);
    assertNotNull(processInstance.getId());
    System.out.println("id " + processInstance.getId() + " "
        + processInstance.getProcessDefinitionId());
  }
View Full Code Here
28
29
30
31
32
33
34
35
36
37
38
39
40
41
  public ActivitiRule activitiRule = new ActivitiRule();

  @Test
  @Deployment(resources = { "diagrams/AutoAssignee.bpmn" })
  public void startProcess() throws Exception {
    RuntimeService runtimeService = activitiRule.getRuntimeService();
    Map<String, Object> variableMap = new HashMap<String, Object>();
    variableMap.put("name", "Activiti");
    ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("AutoAssignee", variableMap);
    assertNotNull(processInstance.getId());
    System.out.println("id " + processInstance.getId() + " " + processInstance.getProcessDefinitionId());

    TaskService taskService = activitiRule.getTaskService();
View Full Code Here
38
39
40
41
42
43
44
45
46
47
48
49
50
51
  public ActivitiRule activitiRule = new ActivitiRule();

  @Test
  @Deployment(resources = { "diagrams/AutoAssignee.bpmn" })
  public void startProcess() throws Exception {
    RuntimeService runtimeService = activitiRule.getRuntimeService();
    Map<String, Object> variableMap = new HashMap<String, Object>();
    variableMap.put("name", "Activiti");
    ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("AutoAssignee", variableMap);
    assertNotNull(processInstance.getId());
    System.out.println("id " + processInstance.getId() + " " + processInstance.getProcessDefinitionId());

    TaskService taskService = activitiRule.getTaskService();
    Map<String, Object> vars = new HashMap<String, Object>();
View Full Code Here
20
21
22
23
24
25
26
27
* @author Joram Barrez
*/
public class StartProcessInstanceTestDelegate implements JavaDelegate {

  public void execute(DelegateExecution execution) throws Exception {
    RuntimeService runtimeService = execution.getEngineServices().getRuntimeService();
    runtimeService.startProcessInstanceByKey("oneTaskProcess");
  }
View Full Code Here
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
   */
  @Test
  public void startProcess() throws Exception {
    RepositoryService repositoryService = activitiRule.getRepositoryService();
    repositoryService.createDeployment().addInputStream("quitFlowOnParallel.bpmn20.xml", new FileInputStream(filename)).deploy();
    RuntimeService runtimeService = activitiRule.getRuntimeService();
    Map<String, Object> variableMap = new HashMap<String, Object>();
    ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("quitFlowOnParallel", variableMap);
    assertNotNull(processInstance.getId());
    System.out.println("id " + processInstance.getId() + " " + processInstance.getProcessDefinitionId());

    // task 1111111
    TaskService taskService = activitiRule.getTaskService();
    Task task111111 = taskService.createTaskQuery().taskName("11111").singleResult();
    taskService.complete(task111111.getId());

    // 两个并行任务
    long count = taskService.createTaskQuery().count();
    assertEquals(2, count);

    // 完成任务：22222222，回到任务11111
    Task task22222222 = taskService.createTaskQuery().taskName("22222222").singleResult();
    variableMap = new HashMap<String, Object>();
    variableMap.put("type", "back");
    taskService.complete(task22222222.getId(), variableMap);

    // 统计任务数量
    count = taskService.createTaskQuery().count();
    assertEquals(2, count);

    // 再次完成任务111111
    task111111 = taskService.createTaskQuery().taskName("11111").singleResult();
    taskService.complete(task111111.getId());

    count = taskService.createTaskQuery().count();
    assertEquals(3, count);
   
    // 清理未完成的流程，避免影响其他测试方法
    runtimeService.deleteProcessInstance(processInstance.getId(), "");
    HistoryService historyService = activitiRule.getHistoryService();
    historyService.deleteHistoricProcessInstance(processInstance.getId());
  }
View Full Code Here
74
75
76
77
78
79
80
81
82
83
84
85
86
   */
  @Test
  public void startProcessWithSignal() throws Exception {
    RepositoryService repositoryService = activitiRule.getRepositoryService();
    repositoryService.createDeployment().addInputStream("quitFlowOnParallelWithSignal.bpmn20.xml", new FileInputStream(filename1)).deploy();
    RuntimeService runtimeService = activitiRule.getRuntimeService();
    Map<String, Object> variableMap = new HashMap<String, Object>();
    ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("quitFlowOnParallelWithSignal", variableMap);
    assertNotNull(processInstance.getId());
    System.out.println("id " + processInstance.getId() + " " + processInstance.getProcessDefinitionId());

    // task 1111111
    TaskService taskService = activitiRule.getTaskService();
View Full Code Here
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
  @Test
  public void startProcess() throws Exception {
    RepositoryService repositoryService = activitiRule.getRepositoryService();
    repositoryService.createDeployment().addInputStream("process1.bpmn20.xml", new FileInputStream(filename)).deploy();
    RuntimeService runtimeService = activitiRule.getRuntimeService();
    Map<String, Object> variableMap = new HashMap<String, Object>();
    variableMap.put("name", "Activiti");
    variableMap.put("users", Arrays.asList("one", "two", "three"));
    ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("process1", variableMap);
    assertNotNull(processInstance.getId());
    System.out.println("id " + processInstance.getId() + " " + processInstance.getProcessDefinitionId());

    List<Execution> list = runtimeService.createExecutionQuery().processDefinitionKey("process1").list();
    for (Execution execution : list) {
      ExecutionEntity entity = (ExecutionEntity) execution;
      System.out.println("executionId=" + execution.getId() + "\tPID=" + execution.getProcessInstanceId() + "\t"
          + entity.getProcessDefinitionId() + "\t execution-parnet_id=" + entity.getParentId());
    }

    List<ProcessInstance> list2 = runtimeService.createProcessInstanceQuery().processDefinitionKey("process1").list();
    System.out.println("processInstance.size=" + list2.size());

    TaskService taskService = activitiRule.getTaskService();
    Task task = taskService.createTaskQuery().singleResult();
    System.out.println("tid=" + task.getId() + "\t eid=" + task.getExecutionId() + "\t pid=" + task.getProcessInstanceId());
View Full Code Here
TOP

Related Classes of org.activiti.engine.RuntimeService

  • com.axemblr.provisionr.cloudstack.CloudStackProvisionr
  • com.axemblr.provisionr.commands.DestroyPoolCommandTest
  • com.axemblr.provisionr.commands.ListPoolsCommandTest
  • com.axemblr.provisionr.commands.ResetRetriesCommandTest
  • com.axemblr.provisionr.core.activities.CheckProcessesEndedTest
  • com.axemblr.provisionr.core.activities.CheckProcessesTest
  • com.axemblr.provisionr.core.activities.KillMachineSetUpProcessesTest
  • com.axemblr.provisionr.core.ProvisionrSupport
  • com.camunda.fox.process.OpenAccountTest
  • com.cisco.step.jenkins.plugins.jenkow.JenkowBuilder
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.