Package org.activiti.engine.runtime

Examples of org.activiti.engine.runtime.Job

137
138
139
140
141
142
143
144
145
146
147
148
  @Deployment
  public void testTimerOnConcurrentTasks() {
    String procId = runtimeService.startProcessInstanceByKey("nonInterruptingOnConcurrentTasks").getId();
    assertEquals(2, taskService.createTaskQuery().count());
   
    Job timer = managementService.createJobQuery().singleResult();
    managementService.executeJob(timer.getId());
    assertEquals(3, taskService.createTaskQuery().count());
   
    // Complete task that was reached by non interrupting timer
    Task task = taskService.createTaskQuery().taskDefinitionKey("timerFiredTask").singleResult();
    taskService.complete(task.getId());
View Full Code Here
159
160
161
162
163
164
165
166
167
168
169
170
  @Deployment(resources = {"org/activiti/engine/test/bpmn/event/timer/BoundaryTimerNonInterruptingEventTest.testTimerOnConcurrentTasks.bpmn20.xml"})
  public void testTimerOnConcurrentTasks2() {
    String procId = runtimeService.startProcessInstanceByKey("nonInterruptingOnConcurrentTasks").getId();
    assertEquals(2, taskService.createTaskQuery().count());
   
    Job timer = managementService.createJobQuery().singleResult();
    managementService.executeJob(timer.getId());
    assertEquals(3, taskService.createTaskQuery().count());
   
    // Complete 2 tasks that will trigger the join
    Task task = taskService.createTaskQuery().taskDefinitionKey("firstTask").singleResult();
    taskService.complete(task.getId());
View Full Code Here
55
56
57
58
59
60
61
62
63
64
65
    }
    return items;
  }

  public Item loadSingleResult(String id) {
    Job job = managementService.createJobQuery().jobId(id).singleResult();
    if (job != null) {
      return new JobListItem(job);     
    }
    return null;
  }
View Full Code Here
103
104
105
106
107
108
109
110
111
112
113
114
   
    // Complete 1 tasks
    taskService.complete(taskService.createTaskQuery().singleResult().getId());
   
    // Fire timer
    Job timer = managementService.createJobQuery().singleResult();
    managementService.executeJob(timer.getId());
   
    Task taskAfterTimer = taskService.createTaskQuery().singleResult();
    assertEquals("taskAfterTimer", taskAfterTimer.getTaskDefinitionKey());
    taskService.complete(taskAfterTimer.getId());
    assertProcessEnded(procId);
View Full Code Here
191
192
193
194
195
196
197
198
199
200
201
202
   
    List<Task> tasks = taskService.createTaskQuery().list();
    taskService.complete(tasks.get(0).getId());
   
    // Fire timer
    Job timer = managementService.createJobQuery().singleResult();
    managementService.executeJob(timer.getId());
   
    Task taskAfterTimer = taskService.createTaskQuery().singleResult();
    assertEquals("taskAfterTimer", taskAfterTimer.getTaskDefinitionKey());
    taskService.complete(taskAfterTimer.getId());
    assertProcessEnded(procId);
View Full Code Here
453
454
455
456
457
458
459
460
461
462
463
464
    taskService.complete(tasks.get(1).getId());
    tasks = taskService.createTaskQuery().list();
    assertEquals(2, tasks.size());

    // Fire timer
    Job timer = managementService.createJobQuery().singleResult();
    managementService.executeJob(timer.getId());
   
    Task taskAfterTimer = taskService.createTaskQuery().singleResult();
    assertEquals("taskAfterTimer", taskAfterTimer.getTaskDefinitionKey());
    taskService.complete(taskAfterTimer.getId());
   
View Full Code Here
510
511
512
513
514
515
516
517
518
519
520
521
    // Complete one task, to make it a bit more trickier
    List<Task> tasks = taskService.createTaskQuery().taskAssignee("kermit").list();
    taskService.complete(tasks.get(0).getId());
   
    // Fire timer
    Job timer = managementService.createJobQuery().singleResult();
    managementService.executeJob(timer.getId());
   
    Task taskAfterTimer = taskService.createTaskQuery().singleResult();
    assertEquals("taskAfterTimer", taskAfterTimer.getTaskDefinitionKey());
    taskService.complete(taskAfterTimer.getId());
   
View Full Code Here
561
562
563
564
565
566
567
568
569
570
571
572
    // Complete two tasks
    taskService.complete(tasks.get(0).getId());
    taskService.complete(tasks.get(1).getId());
   
    // Fire timer
    Job timer = managementService.createJobQuery().singleResult();
    managementService.executeJob(timer.getId());
   
    Task taskAfterTimer = taskService.createTaskQuery().singleResult();
    assertEquals("taskAfterTimer", taskAfterTimer.getTaskDefinitionKey());
    taskService.complete(taskAfterTimer.getId());
   
View Full Code Here
629
630
631
632
633
634
635
636
637
638
639
640
    for (int i=0; i<3; i++) {
      taskService.complete(tasks.get(i).getId());
    }
   
    // Fire timer
    Job timer = managementService.createJobQuery().singleResult();
    managementService.executeJob(timer.getId());
   
    Task taskAfterTimer = taskService.createTaskQuery().singleResult();
    assertEquals("taskAfterTimer", taskAfterTimer.getTaskDefinitionKey());
    taskService.complete(taskAfterTimer.getId());
   
View Full Code Here
704
705
706
707
708
709
710
711
712
713
714
715
    assertEquals("task two", tasks.get(1).getName());
    taskService.complete(tasks.get(0).getId());
    taskService.complete(tasks.get(1).getId());
   
    // Fire timer
    Job timer = managementService.createJobQuery().singleResult();
    managementService.executeJob(timer.getId());
   
    Task taskAfterTimer = taskService.createTaskQuery().singleResult();
    assertEquals("taskAfterTimer", taskAfterTimer.getTaskDefinitionKey());
    taskService.complete(taskAfterTimer.getId());
   
View Full Code Here
TOP

Related Classes of org.activiti.engine.runtime.Job

  • org.activiti.camel.ErrorHandlingTest
  • org.activiti.engine.test.api.event.ActivityEventsTest
  • org.activiti.engine.test.api.event.JobEventsTest
  • org.activiti.engine.test.api.event.SignalThrowingEventListenerTest
  • org.activiti.engine.test.api.mgmt.JobQueryTest
  • org.activiti.engine.test.api.mgmt.ManagementServiceTest
  • org.activiti.engine.test.api.runtime.ProcessInstanceSuspensionTest
  • org.activiti.engine.test.api.tenant.TenancyTest
  • org.activiti.engine.test.bpmn.async.AsyncTaskTest
  • org.activiti.engine.test.bpmn.event.timer.BoundaryTimerEventTest
    • 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.