org.camunda.bpm.engine.runtime.Job.getId()方法的使用及代码示例

x33g5p2x  于2022-01-22 转载在 其他  
字(9.4k)|赞(0)|评价(0)|浏览(111)

本文整理了Java中org.camunda.bpm.engine.runtime.Job.getId()方法的一些代码示例，展示了Job.getId()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Job.getId()方法的具体详情如下：
包路径：org.camunda.bpm.engine.runtime.Job
类名称：Job
方法名：getId

Job.getId介绍

[英]Returns the unique identifier for this job.
[中]返回此作业的唯一标识符。

代码示例

代码示例来源：origin: camunda/camunda-bpm-platform

public void setRetries(Batch batch, int count, int retries) {
 List<Job> jobs = getExecutionJobs(batch);
 assertTrue(jobs.size() >= count);
 ManagementService managementService = getManagementService();
 for (int i = 0; i < count; i++) {
  managementService.setJobRetries(jobs.get(i).getId(), retries);
 }
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Test
public void testSetJobDueDateWithNoAuthenticatedTenant() {
 Job timerJob = managementService.createJobQuery().processInstanceId(processInstance.getId()).singleResult();
 
 identityService.setAuthentication("aUserId", null);
 // then
 thrown.expect(ProcessEngineException.class);
 thrown.expectMessage("Cannot update the job '" + timerJob.getId() +"' because it belongs to no authenticated tenant.");
 // when
 managementService.setJobDuedate(timerJob.getId(), new Date());
}

代码示例来源：origin: camunda/camunda-bpm-platform

protected void executeJob() {
 Job job = managementService.createJobQuery().singleResult();
 assertNotNull(job);
 managementService.executeJob(job.getId());
}

代码示例来源：origin: camunda/camunda-bpm-platform

private int executeJob(String processInstanceId) {
 Job job = fetchJob(processInstanceId);
 try {
  managementService.executeJob(job.getId());
 } catch (Exception e) {
  // ignore
 }
 job = fetchJob(processInstanceId);
 return job.getRetries();
}

代码示例来源：origin: camunda/camunda-bpm-platform

protected void executeSeedAndBatchJobs(Batch batch) {
 Job job = managementService.createJobQuery().jobDefinitionId(batch.getSeedJobDefinitionId()).singleResult();
 // seed job
 managementService.executeJob(job.getId());
 for (Job pending : managementService.createJobQuery().jobDefinitionId(batch.getBatchJobDefinitionId()).list()) {
  managementService.executeJob(pending.getId());
 }
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Test
public void testQueryByConfiguration() {
 String jobId = managementService.createJobQuery().processInstanceId(processInstanceIds.get(0)).singleResult().getId();
 IncidentQuery query = runtimeService.createIncidentQuery().configuration(jobId);
 assertEquals(1, query.count());
 List<Incident> incidents = query.list();
 assertFalse(incidents.isEmpty());
 assertEquals(1, incidents.size());
}

代码示例来源：origin: camunda/camunda-bpm-platform

public void executeSeedAndBatchJobs(Batch batch) {
 Job job = engineRule.getManagementService().createJobQuery().jobDefinitionId(batch.getSeedJobDefinitionId()).singleResult();
 // seed job
 managementService.executeJob(job.getId());
 for (Job pending : managementService.createJobQuery().jobDefinitionId(batch.getBatchJobDefinitionId()).list()) {
  managementService.executeJob(pending.getId());
 }
}

代码示例来源：origin: camunda/camunda-bpm-platform

protected void executeSeedJob(Batch batch) {
 String seedJobDefinitionId = batch.getSeedJobDefinitionId();
 Job seedJob = managementService.createJobQuery().jobDefinitionId(seedJobDefinitionId).singleResult();
 assertNotNull(seedJob);
 managementService.executeJob(seedJob.getId());
}

代码示例来源：origin: camunda/camunda-bpm-platform

public void testGetExceptionStacktraceWithReadInstancePermissionOnAnyProcessDefinition() {
 // given
 String processInstanceId = startProcessAndExecuteJob(ONE_INCIDENT_PROCESS_KEY).getId();
 String jobId = selectJobByProcessInstanceId(processInstanceId).getId();
 createGrantAuthorization(PROCESS_DEFINITION, ANY, userId, READ_INSTANCE);
 // when
 String jobExceptionStacktrace = managementService.getJobExceptionStacktrace(jobId);
 // then
 assertNotNull(jobExceptionStacktrace);
}

代码示例来源：origin: camunda/camunda-bpm-platform

public void testDeleteJobWithUpdateInstancePermissionOnProcessDefinition() {
 // given
 String processInstanceId = startProcessInstanceByKey(TIMER_BOUNDARY_PROCESS_KEY).getId();
 createGrantAuthorization(PROCESS_DEFINITION, TIMER_BOUNDARY_PROCESS_KEY, userId, UPDATE_INSTANCE);
 String jobId = selectJobByProcessInstanceId(processInstanceId).getId();
 // when
 managementService.deleteJob(jobId);
 // then
 Job job = selectJobByProcessInstanceId(processInstanceId);
 assertNull(job);
}

代码示例来源：origin: camunda/camunda-bpm-platform

public void testSetJobDueDateWithUpdateInstancePermissionOnAnyProcessDefinition() {
 // given
 String processInstanceId = startProcessInstanceByKey(TIMER_BOUNDARY_PROCESS_KEY).getId();
 createGrantAuthorization(PROCESS_DEFINITION, ANY, userId, UPDATE_INSTANCE);
 String jobId = selectJobByProcessInstanceId(processInstanceId).getId();
 // when
 managementService.setJobDuedate(jobId, null);
 // then
 Job job = selectJobById(jobId);
 assertNull(job.getDuedate());
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Deployment(resources = "org/camunda/bpm/engine/test/bpmn/job/oneTaskProcess.bpmn20.xml")
public void testSetJobDuedateNonTimerJob(){
 runtimeService.startProcessInstanceByKey("oneTaskProcess");
 Job job = managementService.createJobQuery().processDefinitionKey("oneTaskProcess").singleResult();
 assertNotNull(job);
 managementService.setJobDuedate(job.getId(), new Date());
 job = managementService.createJobQuery().processDefinitionKey("oneTaskProcess").singleResult();
 assertNotNull(job.getDuedate());
}

代码示例来源：origin: camunda/camunda-bpm-platform

public void testExecuteJobWithUpdatePermissionOnProcessInstance() {
 // given
 String processInstanceId = startProcessInstanceByKey(TIMER_BOUNDARY_PROCESS_KEY).getId();
 createGrantAuthorization(PROCESS_INSTANCE, processInstanceId, userId, UPDATE);
 String jobId = selectJobByProcessInstanceId(processInstanceId).getId();
 // when
 managementService.executeJob(jobId);
 // then
 Task task = selectSingleTask();
 assertNotNull(task);
 assertEquals("taskAfterBoundaryEvent", task.getTaskDefinitionKey());
}

代码示例来源：origin: camunda/camunda-bpm-platform

public void testExecuteJobWithUpdateInstancePermissionOnAnyProcessDefinition() {
 // given
 String processInstanceId = startProcessInstanceByKey(TIMER_BOUNDARY_PROCESS_KEY).getId();
 createGrantAuthorization(PROCESS_DEFINITION, ANY, userId, UPDATE_INSTANCE);
 String jobId = selectJobByProcessInstanceId(processInstanceId).getId();
 // when
 managementService.executeJob(jobId);
 // then
 Task task = selectSingleTask();
 assertNotNull(task);
 assertEquals("taskAfterBoundaryEvent", task.getTaskDefinitionKey());
}

代码示例来源：origin: camunda/camunda-bpm-platform

public void testSetJobRetriesWithUpdatePermissionOnProcessInstance() {
 // given
 String processInstanceId = startProcessInstanceByKey(TIMER_BOUNDARY_PROCESS_KEY).getId();
 createGrantAuthorization(PROCESS_INSTANCE, processInstanceId, userId, UPDATE);
 String jobId = selectJobByProcessInstanceId(processInstanceId).getId();
 // when
 managementService.setJobRetries(jobId, 1);
 // then
 Job job = selectJobById(jobId);
 assertNotNull(job);
 assertEquals(1, job.getRetries());
}

代码示例来源：origin: camunda/camunda-bpm-platform

public void testSetJobRetriesWithRetryJobInstancePermissionOnProcessDefinition() {
 // given
 String processInstanceId = startProcessInstanceByKey(TIMER_BOUNDARY_PROCESS_KEY).getId();
 createGrantAuthorization(PROCESS_DEFINITION, TIMER_BOUNDARY_PROCESS_KEY, userId, ProcessDefinitionPermissions.RETRY_JOB);
 String jobId = selectJobByProcessInstanceId(processInstanceId).getId();
 // when
 managementService.setJobRetries(jobId, 1);
 // then
 Job job = selectJobById(jobId);
 assertNotNull(job);
 assertEquals(1, job.getRetries());
}

代码示例来源：origin: camunda/camunda-bpm-platform

public void testSetJobRetriesWithUpdateRetryJobPermissionOnAnyProcessDefinition() {
 // given
 String processInstanceId = startProcessInstanceByKey(TIMER_BOUNDARY_PROCESS_KEY).getId();
 createGrantAuthorization(PROCESS_DEFINITION, ANY, userId, ProcessDefinitionPermissions.RETRY_JOB);
 String jobId = selectJobByProcessInstanceId(processInstanceId).getId();
 // when
 managementService.setJobRetries(jobId, 1);
 // then
 Job job = selectJobById(jobId);
 assertNotNull(job);
 assertEquals(1, job.getRetries());
}

代码示例来源：origin: camunda/camunda-bpm-platform

public void testSuspendJobByIdWihtUpdatePermissionOnProcessDefinition() {
 // given
 String processInstanceId = startProcessInstanceByKey(TIMER_BOUNDARY_PROCESS_KEY).getId();
 String jobId = selectJobByProcessInstanceId(processInstanceId).getId();
 createGrantAuthorization(PROCESS_DEFINITION, TIMER_BOUNDARY_PROCESS_KEY, userId, UPDATE_INSTANCE);
 // when
 managementService.suspendJobById(jobId);
 // then
 Job job = selectJobByProcessInstanceId(processInstanceId);
 assertNotNull(job);
 assertTrue(job.isSuspended());
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Deployment(resources = {"org/camunda/bpm/engine/test/history/HistoricJobLogTest.testAsyncContinuation.bpmn20.xml"})
public void testQueryBySuccessLog() {
 runtimeService.startProcessInstanceByKey("process", Variables.createVariables().putValue("fail", false));
 String jobId = managementService.createJobQuery().singleResult().getId();
 managementService.executeJob(jobId);
 HistoricJobLogQuery query = historyService.createHistoricJobLogQuery().successLog();
 verifyQueryResults(query, 1);
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Deployment(resources = {"org/camunda/bpm/engine/test/api/mgmt/timerOnTask.bpmn20.xml"})
public void testDeleteJobDeletion() {
 ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("timerOnTask");
 Job timerJob = managementService.createJobQuery().processInstanceId(processInstance.getId()).singleResult();
 assertNotNull("Task timer should be there", timerJob);
 managementService.deleteJob(timerJob.getId());
 timerJob = managementService.createJobQuery().processInstanceId(processInstance.getId()).singleResult();
 assertNull("There should be no job now. It was deleted", timerJob);
}

内容来源于网络，如有侵权，请联系作者删除！

Job

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com