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

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

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

Job.getProcessDefinitionKey介绍

[英]Returns the key of the process definition which created the job.
[中]返回创建作业的流程定义的键。

代码示例

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

public Job build() {
  Job mockJob = mock(Job.class);
  when(mockJob.getId()).thenReturn(id);
  when(mockJob.getDuedate()).thenReturn(dueDate);
  when(mockJob.getExceptionMessage()).thenReturn(exceptionMessage);
  when(mockJob.getExecutionId()).thenReturn(executionId);
  when(mockJob.getProcessInstanceId()).thenReturn(processInstanceId);
  when(mockJob.getProcessDefinitionId()).thenReturn(processDefinitionId);
  when(mockJob.getProcessDefinitionKey()).thenReturn(processDefinitionKey);
  when(mockJob.getRetries()).thenReturn(retries);
  when(mockJob.isSuspended()).thenReturn(suspended);
  when(mockJob.getPriority()).thenReturn(priority);
  when(mockJob.getJobDefinitionId()).thenReturn(jobDefinitionId);
  when(mockJob.getTenantId()).thenReturn(tenantId);
  when(mockJob.getCreateTime()).thenReturn(createTime);
  return mockJob;
}

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

@Deployment
public void testLongProcessDefinitionKey() {
 String key = "myrealrealrealrealrealrealrealrealrealrealreallongprocessdefinitionkeyawesome";
 String processInstanceId = runtimeService.startProcessInstanceByKey(key).getId();
 Job job = managementService.createJobQuery().processInstanceId(processInstanceId).singleResult();
 assertEquals(key, job.getProcessDefinitionKey());
}

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

public static JobDto fromJob(Job job) {
 JobDto dto = new JobDto();
 dto.id = job.getId();
 dto.jobDefinitionId = job.getJobDefinitionId();
 dto.processInstanceId = job.getProcessInstanceId();
 dto.processDefinitionId = job.getProcessDefinitionId();
 dto.processDefinitionKey = job.getProcessDefinitionKey();
 dto.executionId = job.getExecutionId();
 dto.exceptionMessage = job.getExceptionMessage();
 dto.retries = job.getRetries();
 dto.dueDate = job.getDuedate();
 dto.suspended = job.isSuspended();
 dto.priority = job.getPriority();
 dto.tenantId = job.getTenantId();
 dto.createTime = job.getCreateTime();
 return dto;
}

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

@Deployment
 public void FAILING_testLongProcessDefinitionKey() {
  String key = "myrealrealrealrealrealrealrealrealrealrealreallongprocessdefinitionkeyawesome";
  String processInstanceId = runtimeService.startProcessInstanceByKey(key).getId();

  Job job = managementService.createJobQuery().processInstanceId(processInstanceId).singleResult();

  assertEquals(key, job.getProcessDefinitionKey());
 }
}

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

@Deployment(resources = {"org/camunda/bpm/engine/test/history/HistoricJobLogTest.testAsyncContinuation.bpmn20.xml"})
public void testQueryByProcessDefinitionKey() {
 runtimeService.startProcessInstanceByKey("process");
 String processDefinitionKey = managementService.createJobQuery().singleResult().getProcessDefinitionKey();
 HistoricJobLogQuery query = historyService.createHistoricJobLogQuery().processDefinitionKey(processDefinitionKey);
 verifyQueryResults(query, 1);
}

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

public void testStandaloneJobQueryWithoutAuthorization() {
 // given
 Date startTime = new Date();
 ClockUtil.setCurrentTime(startTime);
 long oneWeekFromStartTime = startTime.getTime() + (7 * 24 * 60 * 60 * 1000);
 disableAuthorization();
 // creates a new "standalone" job
 managementService.suspendJobDefinitionByProcessDefinitionKey(TIMER_START_PROCESS_KEY, true, new Date(oneWeekFromStartTime));
 enableAuthorization();
 // when
 JobQuery query = managementService.createJobQuery();
 // then
 verifyQueryResults(query, 1);
 Job job = query.singleResult();
 assertNotNull(job);
 assertNull(job.getProcessInstanceId());
 assertNull(job.getProcessDefinitionKey());
 deleteJob(job.getId());
}

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

public static JobDto fromJob(Job job) {
 JobDto dto = new JobDto();
 dto.id = job.getId();
 dto.jobDefinitionId = job.getJobDefinitionId();
 dto.processInstanceId = job.getProcessInstanceId();
 dto.processDefinitionId = job.getProcessDefinitionId();
 dto.processDefinitionKey = job.getProcessDefinitionKey();
 dto.executionId = job.getExecutionId();
 dto.exceptionMessage = job.getExceptionMessage();
 dto.retries = job.getRetries();
 dto.dueDate = job.getDuedate();
 dto.suspended = job.isSuspended();
 dto.priority = job.getPriority();
 dto.tenantId = job.getTenantId();
 dto.createTime = job.getCreateTime();
 return dto;
}

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

public void testQueryWithReadInstancePermissionOnTimerStartProcessDefinition() {
 // given
 startProcessInstanceByKey(TIMER_BOUNDARY_PROCESS_KEY);
 createGrantAuthorization(PROCESS_DEFINITION, TIMER_START_PROCESS_KEY, userId, READ_INSTANCE);
 // when
 JobQuery query = managementService.createJobQuery();
 // then
 verifyQueryResults(query, 1);
 Job job = query.singleResult();
 assertNull(job.getProcessInstanceId());
 assertEquals(TIMER_START_PROCESS_KEY, job.getProcessDefinitionKey());
}

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

public void testQueryWithReadInstancePermissionOnTimerBoundaryProcessDefinition() {
 // given
 String processInstanceId = startProcessInstanceByKey(TIMER_BOUNDARY_PROCESS_KEY).getId();
 createGrantAuthorization(PROCESS_DEFINITION, TIMER_BOUNDARY_PROCESS_KEY, userId, READ_INSTANCE);
 // when
 JobQuery query = managementService.createJobQuery();
 // then
 verifyQueryResults(query, 1);
 Job job = query.singleResult();
 assertEquals(processInstanceId, job.getProcessInstanceId());
 assertEquals(TIMER_BOUNDARY_PROCESS_KEY, job.getProcessDefinitionKey());
}

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

public void assertJobCreated(String activityId, String handlerType) {
 JobDefinition jobDefinitionAfter = snapshotAfterMigration.getJobDefinitionForActivityIdAndType(activityId, handlerType);
 assertNotNull("Expected that a job definition for activity '" + activityId + "' exists after migration", jobDefinitionAfter);
 Job jobAfter = snapshotAfterMigration.getJobForDefinitionId(jobDefinitionAfter.getId());
 assertNotNull("Expected that a job for activity '" + activityId + "' exists after migration", jobAfter);
 assertTimerJob(jobAfter);
 assertEquals(jobDefinitionAfter.getProcessDefinitionId(), jobAfter.getProcessDefinitionId());
 assertEquals(jobDefinitionAfter.getProcessDefinitionKey(), jobAfter.getProcessDefinitionKey());
 for (Job job : snapshotBeforeMigration.getJobs()) {
  if (jobAfter.getId().equals(job.getId())) {
   fail("Expected job '" + jobAfter.getId() + "' to be created first after migration");
  }
 }
}

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

public void testQueryForStandaloneHistoricIncidents() {
 // given
 disableAuthorization();
 repositoryService.suspendProcessDefinitionByKey(ONE_INCIDENT_PROCESS_KEY, true, new Date());
 String jobId = null;
 List<Job> jobs = managementService.createJobQuery().list();
 for (Job job : jobs) {
  if (job.getProcessDefinitionKey() == null) {
   jobId = job.getId();
   break;
  }
 }
 managementService.setJobRetries(jobId, 0);
 enableAuthorization();
 // when
 HistoricIncidentQuery query = historyService.createHistoricIncidentQuery();
 // then
 verifyQueryResults(query, 1);
 disableAuthorization();
 managementService.deleteJob(jobId);
 enableAuthorization();
 clearDatabase();
}

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

public void testQueryForStandaloneIncidents() {
 // given
 disableAuthorization();
 repositoryService.suspendProcessDefinitionByKey(ONE_INCIDENT_PROCESS_KEY, true, new Date());
 String jobId = null;
 List<Job> jobs = managementService.createJobQuery().list();
 for (Job job : jobs) {
  if (job.getProcessDefinitionKey() == null) {
   jobId = job.getId();
   break;
  }
 }
 managementService.setJobRetries(jobId, 0);
 enableAuthorization();
 // when
 IncidentQuery query = runtimeService.createIncidentQuery();
 // then
 verifyQueryResults(query, 1);
 disableAuthorization();
 managementService.deleteJob(jobId);
 enableAuthorization();
 clearDatabase();
}

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

public void testSetJobDueDateWithoutAuthorization() {
 // given
 Job job = selectAnyJob();
 String jobId = job.getId();
 try {
  // when
  managementService.setJobDuedate(jobId, new Date());
  fail("Exception expected: It should not be possible to set the job due date");
 } catch (AuthorizationException e) {
  // then
  // then
  String message = e.getMessage();
  assertTextPresent(userId, message);
  assertTextPresent(UPDATE.getName(), message);
  assertTextPresent(PROCESS_INSTANCE.resourceName(), message);
  assertTextPresent(UPDATE_INSTANCE.getName(), message);
  assertTextPresent(job.getProcessDefinitionKey(), message);
  assertTextPresent(PROCESS_DEFINITION.resourceName(), message);
 }
}

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

public void testDeleteJobWithoutAuthorization() {
 // given
 Job job = selectAnyJob();
 String jobId = job.getId();
 try {
  // when
  managementService.deleteJob(jobId);
  fail("Exception expected: It should not be possible to delete the job");
 } catch (AuthorizationException e) {
  // then
  String message = e.getMessage();
  assertTextPresent(userId, message);
  assertTextPresent(UPDATE.getName(), message);
  assertTextPresent(PROCESS_INSTANCE.resourceName(), message);
  assertTextPresent(UPDATE_INSTANCE.getName(), message);
  assertTextPresent(job.getProcessDefinitionKey(), message);
  assertTextPresent(PROCESS_DEFINITION.resourceName(), message);
 }
}

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

public void testExecuteJobWithoutAuthorization() {
 // given
 Job job = selectAnyJob();
 String jobId = job.getId();
 try {
  // when
  managementService.executeJob(jobId);
  fail("Exception expected: It should not be possible to execute the job");
 } catch (AuthorizationException e) {
  // then
  String message = e.getMessage();
  assertTextPresent(userId, message);
  assertTextPresent(UPDATE.getName(), message);
  assertTextPresent(PROCESS_INSTANCE.resourceName(), message);
  assertTextPresent(UPDATE_INSTANCE.getName(), message);
  assertTextPresent(job.getProcessDefinitionKey(), message);
  assertTextPresent(PROCESS_DEFINITION.resourceName(), message);
 }
}

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

@Test
public void createDeletionJobsByIds() {
 // given
 rule.getProcessEngineConfiguration().setBatchJobsPerSeed(5);
 Batch batch = historyService.deleteHistoricDecisionInstancesAsync(decisionInstanceIds, null);
 JobDefinition seedJobDefinition = helper.getSeedJobDefinition(batch);
 JobDefinition deletionJobDefinition = helper.getExecutionJobDefinition(batch);;
 // when
 helper.executeSeedJob(batch);
 // then
 List<Job> deletionJobs = helper.getJobsForDefinition(deletionJobDefinition);
 assertEquals(5, deletionJobs.size());
 for (Job deletionJob : deletionJobs) {
  assertEquals(deletionJobDefinition.getId(), deletionJob.getJobDefinitionId());
  assertEquals(currentTime, deletionJob.getDuedate());
  assertNull(deletionJob.getProcessDefinitionId());
  assertNull(deletionJob.getProcessDefinitionKey());
  assertNull(deletionJob.getProcessInstanceId());
  assertNull(deletionJob.getExecutionId());
 }
 // and the seed job still exists
 Job seedJob = helper.getJobForDefinition(seedJobDefinition);
 assertNotNull(seedJob);
}

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

@Test
public void createModificationJobs() {
 ProcessDefinition processDefinition = testRule.deployAndGetDefinition(instance);
 rule.getProcessEngineConfiguration().setBatchJobsPerSeed(10);
 Batch batch = helper.startAfterAsync("process1", 20, "user1", processDefinition.getId());
 JobDefinition seedJobDefinition = helper.getSeedJobDefinition(batch);
 JobDefinition modificationJobDefinition = helper.getExecutionJobDefinition(batch);;
 helper.executeSeedJob(batch);
 List<Job> modificationJobs = helper.getJobsForDefinition(modificationJobDefinition);
 assertEquals(10, modificationJobs.size());
 for (Job modificationJob : modificationJobs) {
  assertEquals(modificationJobDefinition.getId(), modificationJob.getJobDefinitionId());
  assertEquals(currentTime, modificationJob.getDuedate());
  assertNull(modificationJob.getProcessDefinitionId());
  assertNull(modificationJob.getProcessDefinitionKey());
  assertNull(modificationJob.getProcessInstanceId());
  assertNull(modificationJob.getExecutionId());
 }
 // and the seed job still exists
 Job seedJob = helper.getJobForDefinition(seedJobDefinition);
 assertNotNull(seedJob);
}

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

public void testSetJobRetriesWithoutAuthorization() {
 // given
 Job job = selectAnyJob();
 String jobId = job.getId();
 try {
  // when
  managementService.setJobRetries(jobId, 1);
  fail("Exception expected: It should not be possible to set job retries");
 } catch (AuthorizationException e) {
  // then
  String message = e.getMessage();
  assertTextPresent(userId, message);
  assertTextPresent(UPDATE.getName(), message);
  assertTextPresent(PROCESS_INSTANCE.resourceName(), message);
  assertTextPresent(UPDATE_INSTANCE.getName(), message);
  assertTextPresent(job.getProcessDefinitionKey(), message);
  assertTextPresent(PROCESS_DEFINITION.resourceName(), message);
  assertTextPresent(ProcessInstancePermissions.RETRY_JOB.getName(), message);
  assertTextPresent(ProcessDefinitionPermissions.RETRY_JOB.getName(), message);
 }
}

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

public void assertJobMigrated(Job jobBefore, String activityIdAfter, Date dueDateAfter) {
 Job jobAfter = snapshotAfterMigration.getJobById(jobBefore.getId());
 assertNotNull("Expected that a job with id '" + jobBefore.getId() + "' exists after migration", jobAfter);
 JobDefinition jobDefinitionAfter = snapshotAfterMigration.getJobDefinitionForActivityIdAndType(activityIdAfter, ((JobEntity) jobBefore).getJobHandlerType());
 assertNotNull("Expected that a job definition for activity '" + activityIdAfter + "' exists after migration", jobDefinitionAfter);
 assertEquals(jobBefore.getId(), jobAfter.getId());
 assertEquals("Expected that job is assigned to job definition '" + jobDefinitionAfter.getId() + "' after migration",
   jobDefinitionAfter.getId(), jobAfter.getJobDefinitionId());
 assertEquals("Expected that job is assigned to deployment '" + snapshotAfterMigration.getDeploymentId() + "' after migration",
   snapshotAfterMigration.getDeploymentId(), jobAfter.getDeploymentId());
 assertEquals(dueDateAfter, jobAfter.getDuedate());
 assertEquals(((JobEntity) jobBefore).getType(), ((JobEntity) jobAfter).getType());
 assertEquals(jobBefore.getPriority(), jobAfter.getPriority());
 assertEquals(jobDefinitionAfter.getProcessDefinitionId(), jobAfter.getProcessDefinitionId());
 assertEquals(jobDefinitionAfter.getProcessDefinitionKey(), jobAfter.getProcessDefinitionKey());
}

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

@Deployment(resources = { "org/camunda/bpm/engine/test/bpmn/async/FoxJobRetryCmdTest.testFailedServiceTask.bpmn20.xml" })
public void testQueryJobRetryOperationsById() {
 // given
 process = runtimeService.startProcessInstanceByKey("failedServiceTask");
 Job job = managementService.createJobQuery().processInstanceId(process.getProcessInstanceId()).singleResult();
 managementService.setJobRetries(job.getId(), 10);
 // then
 assertEquals(1, query().entityType(JOB).operationType(OPERATION_TYPE_SET_JOB_RETRIES).count());
 UserOperationLogEntry jobRetryEntry = query()
  .entityType(JOB)
  .jobId(job.getId())
  .operationType(OPERATION_TYPE_SET_JOB_RETRIES)
  .singleResult();
 assertNotNull(jobRetryEntry);
 assertEquals(job.getId(), jobRetryEntry.getJobId());
 assertEquals("3", jobRetryEntry.getOrgValue());
 assertEquals("10", jobRetryEntry.getNewValue());
 assertEquals("retries", jobRetryEntry.getProperty());
 assertEquals(job.getJobDefinitionId(), jobRetryEntry.getJobDefinitionId());
 assertEquals(job.getProcessInstanceId(), jobRetryEntry.getProcessInstanceId());
 assertEquals(job.getProcessDefinitionKey(), jobRetryEntry.getProcessDefinitionKey());
 assertEquals(job.getProcessDefinitionId(), jobRetryEntry.getProcessDefinitionId());
 assertEquals(deploymentId, jobRetryEntry.getDeploymentId());
}

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

Job

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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