Package org.activiti.engine.runtime

Examples of org.activiti.engine.runtime.Job

41
42
43
44
45
46
47
48
49
50
51
  @Deployment
  public void testExclusiveService() {  
    // start process
    runtimeService.startProcessInstanceByKey("exclusive");
    // now there should be 1 exclusive job in the database:
    Job job = managementService.createJobQuery().singleResult();
    assertNotNull(job);
    assertTrue(((JobEntity)job).isExclusive());
              
    waitForJobExecutorToProcessAllJobs(5000L, 25L);
   
View Full Code Here
98
99
100
101
102
103
104
105
106
107
108
109
   
    Task subProcessTask = taskQuery.singleResult();
    assertEquals("Task in subprocess", subProcessTask.getName());
   
    // When the timer is fired (after 2 hours), two concurrent paths should be created
    Job job = managementService.createJobQuery().singleResult();
    managementService.executeJob(job.getId());
   
    List<Task> tasksAfterTimer = taskQuery.list();
    assertEquals(2, tasksAfterTimer.size());
    Task taskAfterTimer1 = tasksAfterTimer.get(0);
    Task taskAfterTimer2 = tasksAfterTimer.get(1);
View Full Code Here
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
    Task taskA = subProcessTasks.get(0);
    Task taskB = subProcessTasks.get(1);
    assertEquals("Task A", taskA.getName());
    assertEquals("Task B", taskB.getName());

    Job job = managementService
      .createJobQuery()
      .processInstanceId(processInstance.getId())
      .singleResult();
   
    managementService.executeJob(job.getId());

    // The inner subprocess should be destoyed, and the tsk after the timer should be active
    Task taskAfterTimer = taskService.createTaskQuery().processInstanceId(processInstance.getId()).singleResult();
    assertEquals("Task after timer", taskAfterTimer.getName());
View Full Code Here
315
316
317
318
319
320
321
322
323
324
325
326
    assertEquals("Task in subprocess B", taskB.getName());
   
    // Firing the timer should destroy all three subprocesses and activate the task after the timer
//    ClockUtil.setCurrentTime(new Date(startTime.getTime() + (2 * 60 * 60 * 1000 ) + 1000));
//    waitForJobExecutorToProcessAllJobs(5000L, 50L);
    Job job = managementService.createJobQuery().singleResult();
    managementService.executeJob(job.getId());
   
    Task taskAfterTimer = taskQuery.singleResult();
    assertEquals("Task after timer", taskAfterTimer.getName());
   
    // Completing the task should end the process instance
View Full Code Here
72
73
74
75
76
77
78
79
80
81
82
    assertEquals("Inner subprocess task 1", tasks.get(0).getName());
    assertEquals("Inner subprocess task 2", tasks.get(1).getName());
   
    // Timer will fire in 2 hours
    ClockUtil.setCurrentTime(new Date(testStartTime.getTime() + ((2 * 60 * 60 *1000) + 5000)));
    Job timer = managementService.createJobQuery().timers().singleResult();
    managementService.executeJob(timer.getId());
   
    Task task = taskService.createTaskQuery().singleResult();
    assertEquals("task outside subprocess", task.getName());
  }
View Full Code Here
120
121
122
123
124
125
126
127
128
129
    assertEquals(1, taskService.createTaskQuery().count());
   
    // Firing job should cancel the user task, destroy the scope,
    // re-enter the task and recreate the task. A new timer should also be created.
    // This didn't happen before 5.11 (new jobs kept being created). See ACT-1427
    Job job = managementService.createJobQuery().singleResult();
    managementService.executeJob(job.getId());
    assertEquals(1, managementService.createJobQuery().count());
    assertEquals(1, taskService.createTaskQuery().count());
  }
View Full Code Here
55
56
57
58
59
60
61
62
63
64
65
    }
    return items;
  }

  public Item loadSingleResult(String id) {
    Job job = repositoryService.createJobQuery().jobId(id).singleResult();
    if (job != null) {
      return new JobListItem(job);     
    }
    return null;
  }
View Full Code Here
132
133
134
135
136
137
138
139
140
141
      fail();
    } catch (ActivitiException e) {}
  }
 
  public void testQueryByExecutionId() {
    Job job = managementService.createJobQuery().processInstanceId(processInstanceIdOne).singleResult();
    JobQuery query = managementService.createJobQuery().executionId(job.getExecutionId());
    assertEquals(query.singleResult().getId(), job.getId());
    verifyQueryResults(query, 1);
  }
View Full Code Here
264
265
266
267
268
269
270
271
272
273
274
 
  public void testJobQueryWithExceptions() throws Throwable {
   
    createJobWithoutExceptionMsg();
   
    Job job = managementService.createJobQuery().jobId(timerEntity.getId()).singleResult();
   
    assertNotNull(job);
   
    List<Job> list = managementService.createJobQuery().withException().list();
    assertEquals(list.size(), 1);
View Full Code Here
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
  }
 
  //helper ////////////////////////////////////////////////////////////
 
  private void setRetries(final String processInstanceId, final int retries) {
    final Job job = managementService.createJobQuery().processInstanceId(processInstanceId).singleResult();
    commandExecutor.execute(new Command<Void>() {
     
      public Void execute(CommandContext commandContext) {
        JobEntity timer = commandContext.getDbSqlSession().selectById(JobEntity.class, job.getId());
        timer.setRetries(retries);
        return null;
      }
     
    });
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.